activemq

0熱度

1回答

我在熔絲日誌中得到錯誤。爲了解決這個問題，我想我會授予db-32.log文件的權限，但它不允許我更改此文件的權限。相反，我得到一個警告「DB-32.log不能更改屬性」請找出錯誤日誌 07:17:20,163 | INFO | AMQ-1-thread-1 | ActiveMQServiceFactory | 197 - io.fabric8.mq.mq-fabric - 1.2.0.red

0熱度

1回答

具有logstash jms輸入插件的持久訂閱者

我需要將來自ActiveMQ代理的文檔編入Elasticsearch。我爲此目的使用logstash，並使用JMS輸入插件（這是基於jriver-jms構建的）。由於我需要確保存儲在ActiveMQ代理主題中的每個文檔都進入Elasticsearch，因此我希望通過logstash建立持久訂閱。我怎樣才能做到這一點？ JMS輸入插件配置中沒有諸如「持久」之類的參數。

1熱度

1回答

如何聆聽activemq中的多個經紀人

我在尋找解決方案時遇到困難，我的偵聽程序代碼在activemq中應偵聽來自多個經紀人的消息。舉一個例子：我們有4個代理（1,2,3,4），它向4個服務器（A，B，C，D）託管的消費者提供消息。 consumerA應該監聽來自broker的響應消息1,2,3,4.如果它發現該消息，則consumerA應該選擇並處理該消息。如果由於某種原因consumerA出現故障，consumerB應該監聽所有4個

-3熱度

1回答

消息與80000個生產者和少數消費者

我們正在尋求實施一個監控系統，我們必須監控來自80,000個節點的一些細節。我們還希望從80,000個節點生成報告。我們正考慮在每個節點上使用客戶端將消息發送到其他程序可以讀取消息並生成累積報告的隊列。我們正在考慮將Kafka/ActiveMQ/RabbitMQ作爲消息傳遞解決方案的一些產品。哪一個更適合？消息生成速率將約爲每節點5-10/s。

0熱度

1回答

camel-activemq brokerURL參數在駝峯路由中無法識別

我正在嘗試使用camel-activemq依賴關係並設置一個正在偵聽activemq隊列的服務。當我嘗試專門設置的駝路的連接，我使用的端點是：「的ActiveMQ：MAILQ用戶名=管理員&密碼=密碼& trustAllPackages =真& concurrentConsumers = 10 & exchangePattern = INONLY & maxConcurrentConsumers

0熱度

1回答

ActiveMQ中BrokerService的用例以及如何正確使用它

我是ActiveMQ的新手。我想研究一下它是如何工作通過檢查Apache的這個鏈接提供的示例代碼： - http://activemq.apache.org/how-should-i-implement-request-response-with-jms.html public class Server implements MessageListener { private stat

1熱度

1回答

ActiveMQ擴展SimpleAuthenticationPlugin thoews NullPointerException

我不能發佈這個問題，除非我寫了更多的描述，而不是源代碼。這就是爲什麼我只寫了幾個文本。我有以下課程。我的目標是通過設置此插件來保護BrokerService。 public class MyAuthenticationPlugin extends SimpleAuthenticationPlugin { private String username ="username";

0熱度

1回答

缺少財產「JMSXDeliveryCount」

按照鏈接 - http://activemq.apache.org/activemq-message-properties.html 消息應該有「JMSXDeliveryCount」用於嘗試的號碼發送消息當從JConsole的消息屬性檢查，它缺少儘管其他像「的JMSXGroupID」 & 「了JMSXGroupSeq」 JMS支持的屬性可注： - 我已經使用標準的ActiveMQ-5.14.

0熱度

1回答

ActiveMQ NMS消費者在C＃中某些情況下沒有收到消息。

ActiveMQ NMS消費者（C＃）無法接收舊消息：我的C＃程序將在收到消息時進行while循環。我每次需要消息並對接收到的消息進行操作時，都會建立NMS消費者連接。問題是每當我啓動程序後發佈的消息發佈後，我的程序第一次連接嘗試，我可以讓他們下載/消耗。但是，如果沒有消息流入，並且在建立第一個連接之前我有一些舊消息，則這些消息不會消耗。我使用了正確的connection.start()。我

-1熱度

1回答

Java一次性事件調度

您能否告訴我們是否有任何解決方案允許在特定時間（不是cron風格）安排某種類型的一次性事件並通過UI和APi輕鬆管理它。我們檢查了ActiveMQ delayed messages，但主要的音樂會是沒有簡單的方法來重新安排活動。唯一的選擇是徹底刪除舊事件並創建新事件。即使對於這個解決方案，也沒有UI，只有程序化。