activemq

0熱度

1回答

我正在使用下面的代碼爲多個使用者創建多個JMS會話以使用消息。我的問題是代碼以單線程方式運行。即使消息存在於隊列中，第二個線程也無法接收任何內容，只是保持輪詢。第一個線程同時完成第一批處理並返回並消耗剩餘的消息。這裏的用法有什麼問題嗎？ static { try { ActiveMQConnectionFactory connectionFactory = new Activ

2熱度

1回答

ActiveMQ代理網絡中的負載平衡

我們使用ActiveMQ並定義了代理網絡（在我們的測試設置中爲2）。我們已經配置了中間商接AMQP連接，我們必須使「updateClusterClients」和「rebalanceClusterClients」像這樣： <transportConnector name="amqp" uri="amqp+ssl://0.0.0.0:5673?maximumConnections=1000&w

0熱度

1回答

stomp.py心跳參數的功能

心跳被提及here用於處理斷開連接。這個參數究竟做了什麼？它是否將數據包發送到AMQ主機，然後等待它們回來？我試過將此參數設置爲heartbeats=(4000, 4000)，但在達到Idle Timeout後，我仍然從負載平衡器斷開連接。

0熱度

1回答

使用apache camel接收來自activemq的消息java DSL

我使用apache駱駝來接收隊列中的所有消息。但我需要提到運行駱駝上下文的線程睡眠時間。現在的問題是它只消費一些消息，即。在指定的睡眠時間內。如果我增加睡眠時間，那麼它會路由所有消息，但它會等待，直到完成休眠時間才能終止程序。我需要的是，駱駝應該路由隊列中的所有消息，然後它應該立即終止。有什麼辦法可以在不指定線程休眠時間的情況下使用java DSL來運行駱駝？示例代碼： import

0熱度

1回答

如何使用curl命令在activemq主題中發佈消息？

如何使用curl在ActiveMQ主題中發佈消息？我想： curl -XPOST -d "body=message" http://admin:[email protected]:8161/api/message?destination=queue://orders.input 但反應是未經授權的用戶401

0熱度

2回答

如何監控activeMQ的隊列到達和調度消息的時間？

有沒有一種方法（第三方軟件或編程）來監視消息到達特定隊列的時間以及消耗的時間？類似的消息到達17時14分22秒565和17時14分22秒598消耗或消息已排隊ň毫秒我看了一下Statistics plugin但它只是給出最大和最小的時間入隊的消息

1熱度

1回答

Spring Boot JMS主題不起作用

Spring Boot JMS主題不能正常工作，它的行爲與隊列類似。示例代碼應用 @SpringBootApplication public class Application extends SpringBootServletInitializer { public static void main(String[] args) { SpringApplication

0熱度

1回答

連接到ActiveMQ服務器的Android應用程序

我想知道是否可以創建通過ActiveMQ服務器發送和接收消息的Android應用程序？如果它已經完成了，你能告訴我一些例子嗎？感謝您抽出時間來閱讀

0熱度

1回答

ActiveMQ - 僅發佈有興趣訂戶的數據的策略？

我有一個消息代理，各個客戶將在短時間內連接一天。該券商維持可在其上發佈的價格爲成千上萬的事情，但在任何給定的時間設定的當前連接的客戶端將只關心這些事情的一小部分的話題。在一個緊密耦合的系統中，客戶端會明確地訂閱特定的東西，服務器會跟蹤低級客戶端連接/斷開連接事件（自動取消訂閱斷開連接的客戶端）並且只發布客戶訂閱的東西的價格。什麼是在消息系統一樣的ActiveMQ更加鬆散耦合世界處理這種事情的

1熱度

1回答

彈簧集成：無法將消息發送到通道

我正在使用spring-framework和spring-integration最新版本，只是使用彈簧集成創建POC應用程序，但無法執行此操作。我有彈簧集成混淆這樣的東西。 <bean id="initUrlQ" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg value="initUrl.Q"