1

为了从交换/队列中获取消息，我应该如何使用 MuleClient.request() 在 java 端进行操作？

尝试做 client.request("amqp://exchangeName?connector=AMQP_Connector", 15000) 但似乎没有用。

或者可能类似于 "client.request("amqp://localhost:5672?exchangeName=name&connector=AMQP_Connector", 15000) ???

另一个问题出现了，如果我想从某个交换和某个队列中获取消息怎么办？我还需要设置 queueName，对吗？或某种将我引导到特定队列的routingKey？

在 Mule 的 AMQP 文档中说：

AMQP Inbound-Endpoint 的 endpointUri 符合：amqp://{exchange-name}/amqp-queue.{queue-name}。因此，使用两个不同的端点指向同一个交换和队列将导致重复的端点Uri。

但什么是“amqp 队列”？我现在正在尝试 amqp://exchange-name/queue-name 但不起作用 - 显然 - 因为它缺少我不知道它是什么的 amqp-queue。文档没有说太多：S

请帮帮我。

谢谢。

4

1 回答 1

2

“amqp-queue”是一个字符串，你应该保持原样，所以下面的模式：

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

将被解决为：

amqp://myExchange/amqp-queue.myQueue

对于名为的交换myExchange和名为的队列myQueue。

于 2013-09-16T18:09:42.380 回答