spring-jms

    1熱度

    1回答

    代碼... @Transactional @JmsListener(destination = "QueueA") public void process(String input) { doSomethingWhichMayThrowException(input); } 考慮以下情況:... 交易開始(使用Spring @Transactional註釋)從QueueA(隊列

    0熱度

    2回答

    我有一個系統,讀出從IBM MQ消息。從這個隊列中,我們有時會得到損壞的數據。如果下一次讀取消息失敗,監聽器將等待5分鐘,然後再繼續。當一條消息失敗3次後,它將被放在退避隊列中。 JMSContainerFacotry設置爲並行運行最大值10。這意味着如果我們收到大量損壞的消息,這些消息每次需要10分鐘以上才能到達退避隊列(這是正常的),但它們最終消耗了所有線程,因此其他消息必須等待所有損壞到達在

    0熱度

    1回答

    我有一個SpringBoot應用程序使用SpringData來保存Oracle數據庫上的數據,並使用spring-boot-starter-activemq來處理JMS隊列。 我在公開一個DELETE Rest WebService,這需要一段時間。而且我不希望我的用戶掛在回覆中。 因此我添加了一個註釋爲@JmsListener的方法,它可以完成這項工作,我用jmsTemplate.convert

    0熱度

    1回答

    我已經定義了一個JMS入站通道適配器作爲以下中Spring集成3.0.1.RELEASE: <int-jms:inbound-channel-adapter channel="inChannel" phase="1000" destination-name="jmsQueue" extract-payload="true" connection-fa

    0熱度

    1回答

    我有一個Java應用程序使用ActiveMQ中的消息。我有使用嵌入式ActiveMQ的JUnit測試用例(版本:5.10.0)。測試用例執行正常,但在執行後引發此錯誤。我嘗試使用最新版本(5.14.0)並引發錯誤。雖然5.8.0沒有錯誤。我看到一個related thread,它描述了ActiveMQ 5.6.0版的相同問題,但看不到解決方案。欣賞你的投入。 @Bean public Conne

    0熱度

    1回答

    AppConfig.xml設置: <bean id="connectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"> <property name="hostName" value="abchost.com /> <property name="port" value="1414" /> <property name="

    0熱度

    1回答

    我正在編寫一個Spring引導應用程序,它將監聽一個或多個JMS主題。我們爲我們的JMS實現選擇了ActiveMQ。 我們主要關注的是性能和可擴展性。我們預計可能會有數千條消息每秒到達。我們提出了兩種備選方案: 使用單個主題和單個@JmsListener方法。在偵聽器內部,檢查JMS屬性以確定處理郵件的正確策略。 @JmsListener(destination = "response", con

    0熱度

    1回答

    針對持久訂戶使用sping-jms的多個併發消費者推薦的解決方案是什麼

    2熱度

    3回答

    我想聽聽使用下面的代碼段的主題。但是它默認監聽隊列。在這種情況下沒有xml配置。我完全依靠註釋。此外,我完全依賴Spring引導提供的AutoConfiguration。我不知道如何將目標類型設置爲主題,在JmsListener中。 Spring JMS大師請幫忙。 @Component public class MyTopicListener { @JmsListener

    1熱度

    1回答

    我有一個應用程序,其中一個消息(具體的相關ID)被放置在一個有四個訂閱者的主題中。當放置消息時,它被4個訂閱者使用,具有相同的相關ID到隊列(reply = 4messages)。現在我懷疑,當消息有重複相關ID。消費者在搜索帶有相關ID的消息時如何知道消息要消費?