OrderListener.java

@Slf4j
@EnableBinding(OrderSink.class)
public class OrderListener
{
    @StreamListener(target = OrderSink.INPUT,condition = "headers['payment_mode']=='cash'")
    public void listenForCashOrder(Order order)
    {
      log.info(" received new CASH order {} ",order.toString());
    }

    @StreamListener(target = OrderSink.INPUT,condition = "headers['payment_mode']=='credit'")
    public void listenForCreditOrder(Order order)
    {
        log.info(" received new CREDIT order {} ",order.toString());
    }

    @StreamListener(target = OrderSink.INPUT,condition = "headers['payment_mode']=='cheque'")
    public void listenForChequeOrder(Order order)
    {
        log.info(" received new CHEQUE order {} ",order.toString());
    }
}