Hi,
Is there any way to get the handle of Connection object when using @jmslistener?
@Bean(name = “FeeBillConnectionFactory”)
public JmsListenerContainerFactory jmsListenerContainerFactory(ConnectionFactory cachingConnectionFactory){
DefaultJmsListenerContainerFactory jmsListenerContainerFactory = new DefaultJmsListenerContainerFactory();
jmsListenerContainerFactory.setConnectionFactory(cachingConnectionFactory);
jmsListenerContainerFactory.setConcurrency(“2-10”);
jmsListenerContainerFactory.setSessionTransacted(true);
jmsListenerContainerFactory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
return jmsListenerContainerFactory;
}
@JmsListener(destination = "security", containerFactory="FeeBillConnectionFactory") //, concurrency = "15-20")
public void handle(Message message, Session session) throws InterruptedException, JMSException {
System.out.println("handle()"+message.getJMSMessageID());
if (message instanceof TextMessage) {
TextMessage tm = (TextMessage) message;
try {
TestFunction tf=new TestFunction(message, session);
Thread t = new Thread(tf);
t.setDaemon(true);
t.start();
}
catch (Exception e) {
e.printStackTrace();
}
} else {
System.out.println("In Spring Reciever"+message.toString());
}