
Untitled
By: a guest on
Aug 20th, 2012 | syntax:
None | size: 0.63 KB | hits: 7 | expires: Never
@Bean
public AbstractJmsListeningContainer jmsContainer() {
final DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
container.setConnectionFactory(jmsConnectionFactory());
container.setDestination(requestsQueue());
container.setSessionTransacted(true);
container.setConcurrentConsumers(5);
container.setMessageListener(messageListenerAdapter());
return container;
}
private MessageListenerAdapter messageListenerAdapter() {
final MessageListenerAdapter adapter = new MessageListenerAdapter(fooRequestProcessor);
adapter.setDefaultListenerMethod("process");
return adapter;
}