Hello,
Here is a slice of code which register messageListener with delegator.
It listens a queue, but I see that sometimes it doesn't receive messages at all or receive after some time.
When I launch my code again it can receive messages with described above conditions.
Could you please explain where is the problem?
| SimpleMessageListenerContainer messageListener = new SimpleMessageListenerContainer(); | ||
| messageListener.setSessionAcknowledgeMode(javax.jms.Session.AUTO_ACKNOWLEDGE); | ||
| messageListener.setSessionTransacted(true); | ||
| messageListener.setConnectionFactory(getCConnectionFactory()); | ||
| messageListener.setDestinationName(endpointAddress); | ||
| messageListener.setMessageListener(new JMSMessageDelegator(coreProcessor)); | ||
| // messageListener.setConcurrentConsumers(concurrentConsumers); | ||
| // messageListener.setClientId(endpointAddress + | ||
| // UUID.randomUUID().toString()); | ||
| // messageListener.setCacheLevel(DefaultMessageListenerContainer.CACHE_AUTO); | ||
| messageListener.start(); |
Comments