activemq

    5熱度

    1回答

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

    2熱度

    2回答

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

    0熱度

    1回答

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

    0熱度

    1回答

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

    0熱度

    1回答

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

    0熱度

    1回答

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

    -1熱度

    1回答

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

    0熱度

    1回答

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

    -1熱度

    1回答

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

    1熱度

    1回答

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