如何使用 muleClient.request 从 Java 实现异步 AMQP-RabbitMQ？答案

【问题标题】：How to use the muleClient.request for Async AMQP-RabbitMQ Implementation from Java?如何使用 muleClient.request 从 Java 实现异步 AMQP-RabbitMQ？
【发布时间】：2013-09-20 22:50:56
【问题描述】：

为了从交换/队列中获取消息，我应该如何使用 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}。所以，使用两个指向同一个交换和队列的不同端点将导致重复的endpointUri。

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

请帮帮我。

谢谢。

【问题讨论】：

"amqp-queue" 是一个字符串，您应该保持原样。
也不要同时问两个问题。
是的，对不起，大卫，你所说的关于 amqp-queue 的内容起作用了 :) 现在需要删除临时队列哈哈哈，谢谢！！你摇滚！
写一个答案让我打勾:)

标签： java rabbitmq mule amqp

【解决方案1】：

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

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

将被解析为：

amqp://myExchange/amqp-queue.myQueue

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

【讨论】：