activemq

1熱度

1回答

我與我的AMQ生產者之一有問題，我遇到了網絡問題，因此無法將消息發送到Q. 但是，服務器打開Q機器的連接並維護它們完整。連接數量增加，Q機器窒息而無法服務於其他生產者和消費者。這裏是我趕上我的「壞」的製片人例外： Caused by: javax.jms.JMSException: Wire format negotiation timeout: peer did not send his wi

0熱度

1回答

無法對消費者進行異步調度並瞭解「預取限制」的相關性

我的理解是，ActiveMQ的默認行爲是向消費者執行異步分發消息，但是當我試圖通過執行Thread.sleep(60000);在我的MessageListener#onMessage()中，代理無法發送排隊的消息，直到它收到來自先前消息分派的確認爲止。因此，我試圖明確設置異步標誌，以防萬一，使用((ActiveMQConnectionFactory)connectionFactory).setD

0熱度

1回答

如何生產者將被擋在緩慢消費者的情況下

我讀到以下從ActiveMQ的文檔here報價：的缺點使用同步消息傳遞是，製片人更容易堵塞，如果有一個緩慢消費者，他正在調度消息。但我不明白生產者通常會因爲消費緩慢而被阻塞，因爲我的理解是JMS客戶端（生產者）會將消息發送到ActiveMQ實例的隊列（經紀人）就是這樣，現在製作人是免費的，換句話說，發送消息的製作人線程可以自由完成/死亡。然後會有一些其他的JMS客戶端（消費者）監聽該隊列，

0熱度

1回答

ActiveMQ的生產者多隊列中的一個會議

怎麼可能使用ActiveMQ的持久連接/會話入隊的消息不同的隊列？我做了什麼： public class ActiveMQProducer { private static final Logger LOGGER = Logger.getLogger(ActiveMQProducer.class); private Connection connection; p

0熱度

1回答

是否有意義創建相同的連接對象，但不同的對話對象

我讀this ActiveMQ documentation並得到了問題有關創建/使用連接和會話對象爲ActiveMQ的，現在如果我創造我了幾位消費者，並讓每個消費者之間使用一個連接對象不同的會話對象，那麼與創建一個連接和一個會話對象相比，是否會有任何性能差異？我不這麼認爲。（不會從多線程問題的角度認爲）我想，如果我有一個連接對象，然後它不會不管我有一個會話對象或多個會話對象爲所有的消費者，因爲

14熱度

1回答

爲什麼ActiveMQ的5.14.x無法啓動嵌入駱駝的JMS組件2.18.3

下面是簡單的彈簧引導工程（版本1.5.2）來演示該問題： https://github.com/lanwen/camel-jms-activemq-test 它阿帕奇駱駝版本2.18.3 分支master一切工作正常，因爲activemq-camel=5.14.4和camel-jms=2.16.3（從中得到及物動詞）春季啓動應用程序與日誌正常啓動： 2017-04-22 00:53:19.647

0熱度

1回答

如何棧收到的消息和批量

處理他們，我想創建一個消費者，其堆疊到達的消息，並等待：直到n消息已經到達。 t秒過去了。來處理整個消息堆棧。 Pre-fetching不是我要找的。我真正需要的是將進程消息放在一起。 class MyListener(stomp.ConnectionListener): def on_message(self, headers, body): print ("Jus

2熱度

1回答

如何在wildfly中配置activemq 10

因此，我正在嘗試將activemq配置爲在wildfly 10實例中工作，但是在遵循如此多的指南之後，我無法弄清楚爲什麼我會得到這個錯誤，當我啓動我的jboss服務器。列表我的jar文件模塊\ SYSTEM \層\基地\組織\阿帕奇\ ActiveMQ的\主我module.xml <?xml version='1.0' encoding='UTF-8'?> <module xmlns="ur

0熱度

1回答

如何在activeMq tcp故障轉移情況下處理連接故障

我正在使用activeMQ tcp故障轉移連接並創建使用者並訂閱生產者生成的主題。現在我該如何管理網絡故障？如果代理和客戶端之間的連接斷開，我怎麼知道連接何時重新建立？另外，我怎麼知道生產者是否正在運行？在生產者重新啓動的情況下;我如何知道它，以便我可以重新訂閱這些主題？

1熱度

1回答

AMQ_SCHEDULED_DELAY在使用stomp.py時不會延遲郵件

我正在Docker容器上運行ActiveMQ服務器。我正在使用AMQ_SCHEDULED_DELAY標題來延遲郵件。 import time import sys import stomp class MyListener(stomp.ConnectionListener): def on_error(self, headers, message): print(