Spring Integration: jms.Connection.setExceptionListener()
У меня есть только один JMS Listner, но несколько очередей. Это правильный способ реализации 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());`
Я получаю следующее исключение
[org.jboss.mq.Connection] Ошибка подключения, используйте javax.jms.Connection.setExceptionListener() для обработки этой ошибки и переподключения org.jboss.mq.SpyJMSException: выход из IOE; - вложенный throwable: (java.net.SocketTimeoutException: тайм-аут чтения)