2013-09-16 71 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