jms

1熱度

1回答

JMS：可以是MessageListener的onMessage中的消息null？

如果我的MessageConsumer正在實現MessageListener（JBoss JMS 1.1 API），是否有消息可能在Method onMessage（消息）中爲空的情況？ import javax.jms.MapMessage; import javax.jms.Message; import javax.jms.MessageListener; @MessageDriv

0熱度

2回答

使用Spring集成一次發送帶有消息負載的單個json對象字符串？

我正在使用spring集成來使用JdbcPollingChannelAdapter輪詢數據庫，然後使用JmsSendingMessageHandler將結果發佈到Activemq隊列中。我使用MappingJackson2MessageConverter將jdbc結果序列化爲json字符串。收到消息後，它將作爲數組列表發送。是否有可能一次只發送一個消息的有效載荷的單個json-serialized

0熱度

1回答

prolog中不允許有內容。通過愛馬仕JMS與良好的xml

我與愛馬仕一起發送一些JMS文件。我有很多JMS隊列將不同類型的消息發送到我的服務器。所以，我遇到了其中一個隊列的問題。爲了便於我的解釋，有問題的隊列是隊列1. 因此，我發送隊列1中的xml，並且有SAXParseException。我閱讀了很多有關這方面的話題，因此我在我的xsd和xml中驗證了第一行UTF-8和UTF-16。並且我的xml文件沒有問題，因爲這個文件在隊列2中沒有問題。這讓我很生

0熱度

1回答

JMS中的發佈服務器可以返回值嗎？

我正在使用JMS將對象發佈到主題中。用戶將讀取該對象，執行一些操作並返回一個值。但是從我在不同代碼中看到的情況來看，發佈者可以將對象發佈到一個主題中，並且它不會收回任何東西。 public void send(Message m){ jmsTemplate.convertAndSend(topic, m); } @JmsListener(destination =

2熱度

1回答

如何配置Wildfly以連接到RabbitMQ？

我有困難的配置JB EAP7使用RabbitMQ的消息代理。我創建了一個rabbitmq模塊，並將其定義爲我的standalone-ha.xml中的全局模塊。模塊/系統/層/基層/ COM/RabbitMQ的/主/ module.xml： <module xmlns="urn:jboss:module:1.1" name="com.rabbitmq"> <resources>

0熱度

2回答

確保與多個消費者的處理訂單

我有2個請求（A和B）按順序發送到隊列。但是，有2個消費者，他們同時處理2個請求。問題：如何確保2個請求將按順序處理（完成後的第一個B然後B將被處理）。

1熱度

1回答

Apache Camel - IBM MQ集成

我有一個Apache camel（版本2.18）項目，該項目通過IBM MQ客戶端向我的合作伙伴的IBM MQ服務器發送文件。但是，我的合作伙伴使用messageId作爲文件名，因此我們必須將特定的文件名設置爲messageId。我的問題是我們如何改變messageId？我試圖添加JMS_IBM_MQMD_MsgId或MsgId或修改JMSMessageId在JMS頭之前，我發送文件到IBM

1熱度

2回答

使用JMS中的CCDT文件連接到IBM MQ

我試圖使用JMS和客戶端通道定義表（CCDT）連接到IBM MQ。當我單獨指定MQ屬性時，我能夠成功連接到QueueManager。但是，當我嘗試使用CCDT文件時，我得到了下面的異常。由於客戶端通道定義表（CCDT）用於確定客戶端應用程序用於連接到隊列管理器的通道定義，因此我沒有設置QueueManager Name。 ERROR> com.ssc.ach.mq.JMSMQReceiver[

0熱度

1回答

帶有玻璃魚的JMS發佈/訂閱者 - 如何查看發送到網頁上的MDB的數據

我有一個收集數據併發送到JMS主題的Web應用程序表單。從主題來看，我可以通過消息驅動bean使用EJB進行檢索。如何在jsf頁面上顯示檢索到的數據？

1熱度

2回答

Apache Camel - Websphere MQ集成

我有一個應用程序使用apache-camel解決方案，並希望通過jms向Websphere MQ Server發送消息，將jms屬性JMS_IBM_MQMD_MsgId轉換爲MQMD字段MQMD.MsgId，以便在消息上設置此值通過駱駝 exchange.getIn().setHeader(WMQConstants.JMS_IBM_MQMD_MSGID, "XXXXXXXXXXXXXXXXXXXX