2013-09-16 70 views
1

爲了從交換/隊列中獲取消息,我該如何通過使用MuleClient.request()來完成Java端?如何使用muleClient.request從Java實現異步AMQP-RabbitMQ實現?

嘗試做client.request(「amqp:// exchangename?connector = AMQP_Connector」,15000),但似乎沒有工作。

或者可能是這樣的 「client.request(」 AMQP://本地主機:5672 exchangeName =名稱&連接器= AMQP_Connector」,15000)???

而另一個問題來了,如果我有什麼?想獲得某些匯率和某些隊列中的消息,我還需要設置QUEUENAME,權利或某種routingKey的,導致我到特定隊列

在對騾子AMQP文檔這樣說:?

AMQP入站端點i的端點URI s符合: amqp:// {exchange-name}/amqp-queue。{queue-name}。因此,使用兩個指向相同交換和隊列的不同端點 會導致重複endpointUri。

但是「amqp-queue」是什麼? 我現在正在嘗試amqp://交換名稱/隊列名稱,但不起作用 - 顯然 - 因爲它缺少那個我不知道它是什麼的amqp隊列。該文件沒有說太多:S

請幫我。

謝謝。

+1

「amqp-queue」是一個字符串,您應該保持原樣。 –

+0

也不要問一個在兩個問題。 –

+0

對不起大衛,它的工作你所說的關於amqp隊列:)現在需要刪除臨時隊列哈哈哈,謝謝!你搖滾! – msqar

回答

2

「AMQP的隊列」是一個字符串,你應該保留原樣,所以下面的模式:

amqp://{exchange-name}/amqp-queue.{queue-name} 

將被解析爲:

amqp://myExchange/amqp-queue.myQueue 

名爲myExchange和交流隊列名爲myQueue