如何防止接收到我生成的 JMS 消息？

Question

这是场景。我有一个遗留系统，它有两部分，A 部分和 B 部分，它们以一种客户端/服务器的方式相互发送消息。我创建了一个适配器，可以将这些消息转换成另一种格式，以便在新系统中使用。消息发布在多个 JMS 主题上。适配器也听这些相同的主题。但是，由于这两个适配器是相同的并且在旧系统的每个部分上运行，我显然会收到与我发送出去的相同的消息。

除了为每个适配器分配具有唯一 ID 的“消息源”并对其进行过滤之外，是否有一种优雅的方法来过滤与我发送的消息相同的传入消息？

感谢您的帮助！

Answer 1

您需要指定订阅者忽略本地消息。这可以在以下位置指定：

• javax.jms.TopicSubsciber.createSubscriber(Topic topic, String messageSelector, boolean noLocal)
• javax.jms.TopicSubsciber.createDurableSubscriber(Topic topic, String messageSelector, boolean noLocal)
• javax.jms.Session.createDurableSubscriber(Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)
• javax.jms.Session.createDurableSubscriber(Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)
• javax.jmx.Session.createConsumer(Destination destination, String messageSelector, boolean noLocal)

关键部分是 noLocal，当设置为 true 时将忽略从同一 javax.jms.Connection 发送的消息。从订户的角度来看，它们不存在。