activemq

5熱度

1回答

我試圖發送一個X？-GB大文件作爲流到一個ActiveMQ隊列進行處理。我知道ActiveMQ supports streams，camel-jms也是如此，但我試圖在隊列上設置的東西似乎沒有任何區別。唯一發生變化的是關閉流緩存結果，而不是「流關閉」異常。我打算使用處理器或自定義類（只要資源得到清理），但這應該是可能的藍圖。如何通過camel-activemq正確處理大文件而不會出現OutOf

2熱度

2回答

我們如何分析Activemq的死信隊列中的消息

然後，代理將消息發送到死信隊列，以便稍後進行分析。這些是來自apache activemq文章的引用。我的策略也是一樣的。我想稍後分析死信隊列中的消息。我怎樣才能做到這一點？

0熱度

1回答

一個主題的多個監聽器如何在Activemq中工作？

我正在使用ActiveMq嵌入式代理。我正在使用pub/sub模型。我有多個訂閱該主題的聽衆。我正在使用默認消息偵聽器容器。所以我開始的話題和用戶的統計數據。用於主題的消息的數目的統計始終爲零。 DestinationStatistics statistics = destination .getDestinationStatistics(); LOG.info(

0熱度

1回答

WSO2如何從ActiveMQ中獲取消息，而無需通過客戶端應用程序調用任何WSO2 API或代理？

WSO2如何從ActiveMQ中獲取消息，而無需通過客戶端應用程序調用任何WSO2 API或代理？ [請注意： - 源系統將發送通過ActiveMQ的和WSO2消息將不得不拿起這些消息] 任何人能提供任何解決方案？我無言以對......

0熱度

1回答

KahaDB錯誤「磁盤上沒有剩餘空間」。如何解決這個問題？

我正在使用activemq。 KahaDB是activemq的默認消息存儲。但它不斷增加，最終耗盡了磁盤空間。即使所有消息都被確認，它仍然會不斷增大，並在其數據存儲區中不斷創建新的日誌文件。我沒有設置與KahaDB相關的屬性，它使用了默認屬性。 broker = new BrokerService(); TransportConnector connector = new Tran

0熱度

1回答

限制在ActiveMq主題中發送消息的訂戶的最大數量

假設有一個ActiveMq實例，並且有100個客戶端正在監聽主題。當在主題中發佈新消息時，是否可以限制接收它的訂閱者數量（僅示例10）？如果現在有其他消息傳遞組件能夠做到這一點，或者存在解決方案/合併最佳實踐？

-1熱度

1回答

在spring啓動時在activeMQ中延遲傳送消息

我想在'x'秒後在任何時間發送一個't'消息，接收器會收到這個消息。這樣做，我已經寫了接收器瞬間。沒有任何延遲接收的發送者代碼 @Autowired private JmsTemplate jmsTemplate; private Queue queue = new ActiveMQQueue("topicName"); public void show(String message)

0熱度

1回答

Activemq - 通過不穩定連接發送大文件的最佳協議

使用案例：需要在隊列上從一臺服務器向另一臺發送大型文件（100 MB的倍數）。目前，我正在使用Activemq Artemis服務器發送大文件作爲ByteMessage，通過tcp協議輸入流的幫助，重新嘗試間隔爲-1，無限次失敗重試。這裏的主要問題是消費者終端連接將大部分是不穩定的，即由於移動性原因斷開與網絡的連接。因此，當在隊列中發送文件時，如果連接斷開並且重新連接的代理應該從事務中斷的地方

-1熱度

1回答

Java ActiveMQ：如何發送消息從客戶端到服務器

我見過很多關於如何從服務器/生產者發送消息到客戶端的代碼和示例，但我失去了如何從客戶端發送消息到服務器。它是否遵循相同的格式？例如，假設我的服務器有5個主題：A，B，C，D，E。我的客戶端只收聽主題C. 所以我的服務器創建一個隊列併發送消息給訂閱者/客戶端。我的客戶端獲取主題C上的消息。它執行一些計算，並且我想要將消息發回給發佈者（例如int）。什麼是必需的步驟？我是否需要爲製作人設定一個目

1熱度

1回答

Activemq PooledConnectionFactory中到期超時的含義是什麼？

我不明白在Activemq PooledConnectionFactory中應用expiryTimeout字段。 java doc表示「允許連接過期，而不考慮負載或空閒時間，這對於故障轉移強制從池中重新連接，重新建立負載平衡或使用主後期恢復很有用」。請給我舉一個例子，其中expiryTimeout場效應真實場景。