java - Apache Qpid - 在消息级别设置路由 key

Question

是否有任何选项可以在 Apache Qpid 中的消息级别设置路由 key 。我目前的做法是

1. 在地址字符串中指定路由键。使用此目标地址创建生产者。

   topic = (主题) context.lookup("目的地");发送者 = session.createProducer(topic);

2. 通过生产者发送消息。

这样所有的消息都有相同的路由键。我想要实现的是为每条消息单独设置一个路由键。

请告诉我是否可以做到

Answer 1

这可以通过指定每条消息的主题轻松完成。当使用 0-10 协议(protocol)时，Qpid 地址方案定义的“主题”将映射到主题的路由键。

Message m = ssn.createMessage();
m.setStringProperty("qpid.subject", "my-subject");
prod.send(m);

这允许您使用标准 JMS 接口(interface)，同时仍然使用 Qpid 附加组件。