OrderListener.java

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

@Slf4j
@EnableBinding(OrderSink.class)
public class OrderListener
{
    @StreamListener(target = OrderSink.INPUT)
    public void listenForOrder(Order order)
    {
      log.info(" received new order ["+order.toString()+"] ");
    }
}