Spring Integration: jms.Connection.setExceptionListener()

227 views Asked by At

i have only one jms listner but multiple queues.this is the right way of implementing jms JBOSS4.2 MQ?

System.out.println("Lookup queue");
Queue queueForResponse = (Queue) context.lookup("/queue/ResponseProcessingQueue");
Queue queueForExcelDownload = (Queue) context.lookup("/queue/ExcelDownloadQueue");
Queue queueForWebHookResponse = (Queue) context.lookup("/queue/WebHookProcessingQueue");
Queue queueForCRMAPIResponse = (Queue) context.lookup("/queue/CRMAPIProcessingQueue");
Queue queueForUploadResponse = (Queue) context.lookup("/queue/UploadResponseQueue");

System.out.println("Start connection");
connection.start();

/* consumer message  */
System.out.println("Create consumer : ");
MessageConsumer consumerForResponse = session.createConsumer(queueForResponse);
MessageConsumer consumerForExcelDownload = session.createConsumer(queueForExcelDownload);
MessageConsumer consumerForWebHook = session.createConsumer(queueForWebHookResponse);
MessageConsumer consumerForCRMAPI = session.createConsumer(queueForCRMAPIResponse);
MessageConsumer consumerForUpload = session.createConsumer(queueForUploadResponse);



System.out.println("set message listener");
consumerForResponse.setMessageListener(new MyMessageReceiver());
consumerForExcelDownload.setMessageListener(new MyMessageReceiver());
consumerForWebHook.setMessageListener(new MyMessageReceiver());
consumerForCRMAPI.setMessageListener(new MyMessageReceiver());
consumerForUpload.setMessageListener(new MyMessageReceiver());`

I get the following exception

[org.jboss.mq.Connection] Connection failure, use javax.jms.Connection.setExceptionListener() to handle this error and reconnect org.jboss.mq.SpyJMSException: Exiting on IOE; - nested throwable: (java.net.SocketTimeoutException: Read timed out)

0

There are 0 answers