我在寫一個從隊列中消費的JMS客戶端。我的經紀人是activemq,如果它很重要。ActiveMQ:沒有經紀人的初始消費者
一個要求是即使代理已關閉,客戶端也應該啓動。在這種情況下,它應該像在隊列中沒有消息一樣,並且一旦代理啓動並且消息開始相應地行爲。
的問題是,在我的代碼:
connectionFactory = new ActiveMQConnectionFactory(url);
Connection connection = connectionFactory.createConnection();
connection.start()
如果代理下來,那麼它陷在connection.start()
。雖然我想要的是connection.start()
以靜默方式返回並繼續嘗試在後臺進行連接,並在消息可用時使用消息,並在消息不能時保持消息。
我該如何做到這一點。
它是JMS隊列還是它的線程間通信隊列? – dimba 2011-02-26 20:50:29