activemq

0熱度

1回答

我們正面臨一個奇怪的問題，我們試圖彈簧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回答

TomEE MySQL上的內部JMS

我使用這個配置來使用TomEE JMS和mysql。 According to OpenEJB Document <Resource id="MyJmsResourceAdapter" type="ActiveMQResourceAdapter"> BrokerXmlConfig = broker:(tcp://localhost:23250) ServerUrl =

0熱度

1回答

ActiveMQ（Java） - 檢查連接活動的時間（即消費者或生產者）

我目前使用Apache ActiveMQ作爲JMS解決方案來在客戶端之間來回發送各種消息。我想檢查特定客戶（即消費者或生產商）的正常運行時間，但我還沒有找到一種方法來做到這一點。我已經檢查了諮詢消息和StatisticsPlugin以瞭解如何執行此操作的任何信息，但沒有發現任何幫助。我可以嘗試在我的Consumer和Producer類中嵌入一個時鐘，並創建一個特殊的諮詢目標來發送消息以從這些類中

0熱度

1回答

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

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

0熱度

1回答

不同類型的MOM（面向消息的中間件）的

我是新來的媽媽的世界，開始學習不同類型的消息框架的，有人能請解釋一下我下面？ JMS VS主動MQ VS兔MQ 春AMQP VS Spring集成春AMQP與兔MQ VS Spring集成與兔MQ 感謝，

0熱度

1回答

春天啓動的WebSocket嵌入式ActiveMQ代理

我試着使用Spring 1.5.4啓動，但總是得到一個錯誤改變，從簡單的經紀人的Web應用程序的嵌入式ActiveMQ代理與STOMP在啓動時 Caused by: java.lang.IllegalArgumentException: No handlers at org.springframework.util.Assert.isTrue(Assert.java:92) ~[spri

0熱度

1回答

以編程方式配置Apache ActiveMQ

我使用Apache ActiveMQ對大量消息進行排隊，然後在一天結束時將它們出列。不過，我對ActiveMQ的運作方式感到困惑。在我的PC上，我沒有安裝ActiveMQ作爲服務，也沒有在某處安裝服務器。我剛纔包括「ActiveMQ的 - 全5.14.5.jar」作爲我的項目Maven的依賴，我使用下面的代碼至今： public static void main(String[] args) th

1熱度

1回答

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

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

0熱度

1回答

如何從報頭值在Apache的駱駝設置隊列名稱

我試着從報頭值設置ActiveMQ的隊列名稱，但其不低於發生的事情是我春DSL <setHeader headerName="x-so-queue-name" id="_setHeader1"> <xpath resultType="java.lang.String">/Message/@IntObjectName</xpath> </setHeader> <log id="_lo

0熱度

2回答

Spring集成 - Apache ActiveMQ到Kafka

我正在使用以下配置來將activemq與kafka集成。我從activemq收到消息並將其轉發給kafka。但是，我注意到消息正從JMS隊列中出列，但消息不會發送到卡夫卡。 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi