Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
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()+"] ");
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment