spring-jms

0熱度

1回答

我有一個簡單的bach作業，它從JMS隊列（ActiveMQ）讀取並寫入文件。批處理作業按預期方式運行，並寫入文件以遵守已設置爲10,000的提交間隔。有這方面的批處理作業隊列中讀取並沒有結束2個觀察值。我看到，隊列中的所有消息都已被使用，但只有當新消息被推送到JMS隊列並且滿足提交間隔時，纔會將最後一個塊寫入文件。它是預期的行爲嗎？我想安排批處理作業，並在該時間點消耗並寫入隊列中的所有消

0熱度

1回答

@JmsListeners的泛型類型？

我有一個類定義了2個JMSListeners。 1個偵聽器用於客戶端從使用JMS的服務器接收的消息MyMessage1。另一個是MyMessage2，它由另一個程序生成，不使用JMS（不是Java程序）。看起來，當我嘗試接收此消息時，我收到了一些JMS Listener異常。它似乎正在使用GenericMessage並嘗試將其轉換爲MyMessage，儘管有效負載指示它是MyMessage2，儘管

1熱度

1回答

如何使用ActiveMQ和Spring集成JMS在多個組中接收一次消息？

我想在創建系統中的用戶時使用消息傳遞服務向其他服務發送消息。接收消息的服務是負載平衡的Spring Boot應用程序（在我們的例子中，Kubernetes環境中的窗格）。我想：在每個服務的每一個盒被配置成接收消息。每個服務中的一個（並且只有一個）吊艙實際上收到每條消息。該消息可以通過這種方式被多個服務接收。因此，在圖片中，「新用戶」消息由Notification Service中的一個窗

2熱度

2回答

NoClassDefFoundError無法初始化類com.ibm.mq.headers.internal.HeaderType

我們已升級到IBM MQ8，並在我們的項目中具有以下依賴項。以下相關性存在 com.ibm.disthub2.dhbcore com.ibm.mq.jmqi com.ibm.mqjms ibm-jaxrpc-client com.ibm.mq com.ibm.mq.headers com.ibm.mq.pcf com.ibm.mq.commonservices 但是在運行主程序，

1熱度

1回答

IBM MQ問題：JMSMQ1113目標未設置名稱

在春季JMS項目中，我嘗試連接到放置在遠程服務器中的IBM MQ QUEUE。代碼可以到達IBM MQ服務器並識別MQ管理器，但是當它嘗試與在.bindings文件中提及其名稱的QUEUE進行通信時（該文件在IBM MQ服務器中生成，並且我將其複製到本地文件夾中和我提到的這個文件夾的名稱作爲JNDI資源），我得到了以下錯誤： INFO - Setup of JMS message listener

1熱度

2回答

spring jmstemplate讀取消息而不刪除（WebSphere MQ）

如何在不從隊列中刪除原始消息的情況下從WebSphere MQ讀取消息。我有Spring應用程序，它從WebSphere MQ讀取消息。閱讀後，我有一個處理方法，它將處理從隊列中檢索的數據。步驟1 response = jmsTemplate.receive(); //Message automatically removed from queue. 步驟2 process(respo

1熱度

1回答

IBM MQ問題：jmscmq0001的WebSphere MQ調用失敗，compcode「2」（「MQCC_FAILED」）的原因「2035」

在春天JMS的項目，我嘗試連接到IBM MQ隊列放在同一個地方，春天客戶端是。當應用程序試圖連接到我得到了以下錯誤的MQ服務器： INFO - Could not refresh JMS Connection for destination 'TI.UNIT1.TRAN.IN' - retrying in 5000 ms. Cause: JMSWMQ2013: L'authentificatio

1熱度

3回答

@JmsListener問題

我使用Spring的@JmsListener（彈簧JMS-4.3.4.RELEASE.jar）使用下面的代碼從ActiveMQ的接收消息： @Component public class TopicSubscriber { @JmsListener(destination="xyz.topic1", subscription="xyz_topic_durable_subscriptio

2熱度

2回答

春天JmsTemplate的 - 添加自定義屬性

我使用了Spring API的JmsTemplate和MappingJackson2MessageConverter（版本：spring-jms-4.3.4.RELEASE.jar），如在下面的代碼發佈消息到ActiveMQ的話題。的TopicPublisher類： @Component public class TopicPublisher { @Autowired

0熱度

2回答

如何限制activemq實例上的重新連接數

我有一個與activemq代理交互的spring JMS應用程序。如果應用程序無法訪問代理，則無限期地重試。我如何配置我的DefaultJmsListenerContainerFactory bean中的activemq.xml文件或soemthing，以便它不會無限期地重試？我看到一個ActiveMQ的ReconnectionPolicy引用，但我不知道如何在activemq.xml中獲取