spring-jms

3熱度

1回答

在我的Spring Boot應用程序中，我配置了嵌入式Apache ActiveMQ。 @Configuration @EnableJms public class ActiveMQConfig { @Bean public Queue queue() { return new ActiveMQQueue("import.decisions.queue");

0熱度

1回答

春JMS 4.3.8 VS 4.0.2和ActiveMQ 5.13.0問題

我們正面臨一個奇怪的問題，我們試圖彈簧JMS-4.0.2升級後的4.3.8和ActiveMQ的留在5.13.0。我們目睹的是在spring-jms或activemq方面持續循環，並且在Tomcat中啓動應用程序後，CPU一直與20-40左右的範圍掛鉤。如果我們回去，只需用4.0.2版本替換spring-jms 4.3.8，那麼在啓動後所有的行爲都會正常進行。彈簧中的「DefaultMessa

0熱度

1回答

Spring Factory創建隊列中的同步消費者

我是Spring Boot的新手，併爲我的大學項目工作編碼，我需要一些幫助。我想創建一個彈簧啓動應用程序，它啓動一個工廠類，它將創建並啓動10個同步客戶端。這些客戶端必須不斷監聽隊列。以下是我的代碼。我不確定，如果我在正確的軌道上，需要一些幫助。我的實現是否正確？我如何確保創建10個同步客戶端？我如何使用標識符來確定哪些消息客戶端處理了消息？ Application.java @SpringBo

1熱度

1回答

春季集成：REST到JMS集成給出超時錯誤

嗨我試圖使用Spring集成實現以下流程。公開REST服務，處理有效內容，將更改後的有效內容寫入JMS並回復到REST服務。 @Bean public IntegrationFlow httpInputFlow() { return IntegrationFlows .from(Http.inboundGateway(「/company」) .requ

0熱度

1回答

DefaultMessageListenerContainer concurrentConsumers和maxConcurrentConsumers處理太多消息的最大限制

我想使用Spring的DefaultMessageListenerContainer同時收聽Queue中的消息（大量消息）。 <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory"

0熱度

2回答

正確的最終途徑遷移JMS事件監聽Spring集成與Spring引導

我得到了處理由一個主題以下列方式JMS事件JmsConfig配置類：它定義了一個@Bean ConnectionFactory，包含ActiveMQ的實現它定義了@Bean JmsListenerContainerFactory實例化一個DefaultJmsListenerContainerFactory並使其通過Boot的DefaultJmsListenerContainerFactoryC

1熱度

1回答

嘗試重新設計Spring集成的JMS配置：重新傳遞策略

我的傳統配置公開了ConnectionFactory @ Bean類型ActiveMQConnectionFactory，並通過activeMQConnectionFactory.setRedeliveryPolicy(..)自定義重新傳遞。我發現Spring集成DSL可以通過RequestHandlerRetryAdvice來處理手柄操作的重新獲取，例如可以配置ExponentialBackO

0熱度

1回答

Spring JMS - 聲明式事務管理使用註釋

我有一些我需要重構的舊代碼，它具有JMS的編程事務管理。有一個計劃的服務，它可以同步讀取所有消息（使用JMS）並逐個處理它們。我正在使用JmsTransactionManager進行交易。我可以用聲明式事務管理使用註釋來管理每封郵件我的交易，而不是他們的管理程序，像這樣： //code from scheduled service's run method private void run()

0熱度

1回答

Came jmsComponent：在不同的bean中設置異常Listener有什麼區別？

我設置了這樣的方式春天JMS組件： <bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp://localhost:61616" /> </bean> <bean id="cach

2熱度

1回答

確定何時在隊列中沒有消息時在SpringBoot中終止Jms偵聽器

什麼是正確的方式或者決定何時終止偵聽器的流行慣例？我似乎無法在任何地方找到確鑿的答案。我正在處理的隊列是IBM的MQ隊列，我通常知道，直到您收到2033錯誤代碼（我的公司在其他應用程序中執行此操作）時纔會讀取，但您可以在此處進行包裝，但對於SpringBoot Jms應用程序這裏的約定是什麼？一旦隊列爲空，監聽器就會掛起，直到有更多的消息到來。我知道如何殺死它，但是我怎麼知道什麼時候？作爲一個例