jms - 如何在发送 JMS 消息或发送到特定服务器之前按消息类型进行过滤？

Question

假设 Active MQ 是代理，并且有 6 台服务器连接了 JMS 侦听器。

当发送一个主题时，所有六台服务器都将使用这些消息。

现在我希望一个特定的服务器只使用消息而不是使用选择器的所有六个，并且应该在发送 JMS 之前对其进行过滤。

如何在 JMS 中定义选择器，以便主题将由特定服务器而不是全部使用。

Answer 1

您需要 JMS消息选择器。发送前无需过滤，接收时即可。仅 ID 为“serv_5”的服务器接收消息的示例：

制片人：

...
Message message = session.createMessage();
message.setObjectProperty("server_id", "serv_5");
producer.send(message);

消费者（MDB）：

@MessageDriven(mappedName="jms/YourQueue", activationConfig =  {
        @ActivationConfigProperty(propertyName = "acknowledgeMode",
                                  propertyValue = "Auto-acknowledge"),
        @ActivationConfigProperty(propertyName = "destinationType",
                                  propertyValue = "javax.jms.Queue"),
        @ActivationConfigProperty(
                                  propertyName="messageSelector",
                                  propertyValue="server_id = 'serv_5'")

    })
public class YourMessageBean implements MessageListener { ..