Setting sessionTransacted to 'true' for the JmsMessageDrivenSourceAdapter (and minor updates in cafe sample).

spring-integration-core/src/main/java/org/springframework/integration/adapter/jms/JmsMessageDrivenSourceAdapter.java

@@ -116,6 +116,7 @@ public class JmsMessageDrivenSourceAdapter extends AbstractSourceAdapter<Object>
 		dmlc.setMaxConcurrentConsumers(this.maxConcurrentConsumers);
 		dmlc.setMaxMessagesPerTask(this.maxMessagesPerTask);
 		dmlc.setIdleTaskExecutionLimit(this.idleTaskExecutionLimit);
+		dmlc.setSessionTransacted(true);
 		dmlc.setAutoStartup(false);
 		ChannelPublishingJmsListener listener = new ChannelPublishingJmsListener(this.getChannel());
 		listener.setMessageConverter(this.messageConverter);