activemq

0熱度

2回答

配置ActiveMQ：如何使用Node.js發送消息到Apache ActiveMQ隊列

我有一個JAVA api需要使用來自ActiveMQ的數據。客戶端向我提供了主機，端口和API密鑰的詳細信息。林在這個ActiveMQ的一個紐比和需要有關如何自隊列工作在TCP協議建立初始隊列連接的建議。我建議用目前我指用各種語言通過ActiveMQ的支持的客戶端庫之一：如何配置或執行（如果我使用「如何發送http://activemq.apache.org/cross-language-

0熱度

1回答

如何探索一條ApacheMQ隊列，查看發送給它的所有消息

我已經開始了和ActiveMQ和能前進，但我無法弄清楚如何我可以查看發送到特定的所有消息隊列。我可以在隊列中，只要它不被消費者食用，但只要它是由消費者消費，我再也看不到在隊列中的消息，看到該消息。在我的項目中，我曾經使用「MQJ Explorer」並連接到一個隊列管理器，在那裏我可以查看所有發送到特定隊列的消息，所以我期待着與ActiveMQ類似的事情。我知道在發送我能有消息標記爲「永久」，

3熱度

1回答

使用nodejs在使用消息選擇器時訂閱ActiveMQ STOMP？

我想使用nodejs訂閱activemq服務器。我現在面臨的問題是，我現在的node-stomp-client（https://github.com/easternbloc/node-stomp-client）正在獲取所有正在發佈的消息，當我真的想使用「消息選擇器」，以便我不會獲得所有消息消息傳到nodejs。有沒有一種方法可以在nodej中使用消息選擇器，就像使用Java訂閱ActiveMQ一樣

0熱度

1回答

使用activeMQ資源適配器的興趣

我在eclipse中創建了一個Java應用程序，讓不同的設備使用發佈/訂閱協議一起通信。我正在使用Jboss和ActiveMQ，我想知道是否應該使用ActiveMQ資源適配器將獨立模式下的代理集成到jboss中，或者我應該只在我的pom.xml文件中添加依賴項並使用顯式java代碼如此處所示http://activemq.apache.org/how-do-i-embed-a-broker-in

0熱度

1回答

阻止生產者在活躍的mq

最近我們一直面臨着activemq的一些問題。生產者能夠連接到代理，但是當我們發送消息時，生產者線程被阻塞。客戶端/生產者既不超時也不拋出異常。我想知道如果我們可以添加任何參數到故障轉移配置故障轉移：（tcp：// localhost：61616，tcp：//srv01.abc.com：61616），以便如果客戶端主服務器超時，該消息可以重定向到故障轉移mq代理。如果有人能在這方面幫助我，那將會很

1熱度

1回答

使用Spring JmsTemplate的/ ActiveMQ的使用請求/應答，而不在隊列中

阻止了其他郵件，我們實施了，我們要等待響應特定的用例分佈式請求/響應類型的架構。我們使用的JMS代理是ActiveMq，代碼使用Spring連接在一起。我們看到的問題是，它看來，如果發送了一堆請求到相同的目的地，任何請求，比如，需要的時間顯著量來完成，塊跟在它後面的請求消息。消費者使用的SessionAwareMessageListener接口僅支持onMessage（）方法。在這裏實現並行性的

0熱度

1回答

ActiveMQ的失效連接的問題

你好我對ActiveMQ的5.10.0工作他們是窗簾的過程，將通過TCP連接進行連接和發送消息到一個隊列，也話題訂閱，總計最大連接數是10000左右經過一番使用面臨的錯誤，因爲在activeMQ超過最大連接，我已經通過activemq控制檯，發現很多TCP連接仍處於活動狀態爲真，並且此連接堆積到10000和ActiveMQ拋出錯誤超過最大連接。爲什麼這個連接永遠處於真正的狀態如何擺脫這種連接有

0熱度

1回答

NMS ActiveMQ忽略代碼中設置的預取限制

我使用的是當前的Apache.NMS 1.7.1和Apache.NMS.ActiveMQ 1.7.2。我使用的是IndividualAcknowledge，所以我試圖保持加載消息的數量很低，因爲如果我有1000個消息加載而沒有加載它們，它會變得非常慢（它每次搜索所有消息的鏈表）。我有以下codesnippets： BlockingCollection<IMessage> _collectio

-3熱度

1回答

Spring + apache camel + activeMQ +隊列整合是否可用完整項目？

任何人都可以幫助我獲得完整的項目爲spring + apache駱駝+ activeMQ +隊列整合？

1熱度

1回答

無法配置涉及的ActiveMQ和嵌入式H2分佈式事務與Atomikos公司

我想在一個嵌入式H2 DB和ActiveMQ的使用Atomikos公司作爲一個春天MVC應用程序底層的JTA實現建立一個分佈式事務。我已經關注或訪問了與我遇到的錯誤相關的web/stackoverflow上的幾乎每個頁面，但一直未能弄清楚。下面是配置的相關部分： @Autowired @Bean(name = "transactionManager") public Pla