jms - AMQP & Openwire - Activemq 经纪人和 2 个不同的消费者

Question

我有一个同时支持 amqp 和 openwire 的 activeMQ 代理。openwire 的生产者(tcp，端口 61616)是否有可能生产到具有使用 amqp 协议(protocol)的消费者的队列？

还是我仅限于同一协议(protocol)的消费者和生产者？

Answer 1

是的，可以使用 ActiveMQ 与 OpenWire JMS 客户端和 AMQP 客户端进行互操作。保存消息的目的地不是单独的空间，因此由一种类型的客户端放置在队列上的消息可由来自其他协议(protocol)的客户端使用。

您唯一需要考虑的是如何将实际消息传达给每个客户端。 ActiveMQ 提供了一个可配置的转换器，它可以在从 AMQP 客户端发送时保留 AMQP 消息的原始字节，或者将该消息转换为更 JMS 风格的消息对象，OpenWire 客户端将作为预期类型(TextMessage、BytesMessage、 map 消息...)。

请参阅 ActiveMQ 文档以获取有关配置和理解 AMQP 到 OpenWire 消息的映射的帮助。

http://activemq.apache.org/amqp.html

如果您想最轻松地处理消息被转换并始终作为正确的 JMS 类型到达 OpenWire 客户端的情况，请在配置中选择 JMS Transformer，如下所示:

<transportConnector name="amqp" uri="amqp://localhost:5672?transport.transformer=jms"/>