0

我只有一个 jms 监听器,但有多个队列。这是实现 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: Exiting on IOE;- 嵌套的 throwable:(java.net.SocketTimeoutException:读取超时)

4

0 回答 0