in generic-examples/amqp/AmqpConnectionBeanConsumer.java [20:23]
public void configure() throws Exception { from("amqp:queue:example?exchangePattern=InOnly") .to("log:info"); }