如何知道监听器是否在JMS中得到消息？

Question

public class CustomerStatusSender {
    private JmsTemplate jmsTemplate;
    private Topic topic;

    public void setJmsTemplate(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

    public void setTopic(Topic topic) {
        this.topic = topic;
    }

    public void simpleSend(final String customerStatusMessage) {
        jmsTemplate.send(topic, new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
                TextMessage message = session.createTextMessage("hello from sender.");
                message.setStringProperty("content", customerStatusMessage);
                return message;
            }
        });
    }
}

这是一个消息侦听器：

public class CustomerStatusListener implements MessageListener {
    public void onMessage(Message message) {
        if (message instanceof TextMessage) {
            try {
                System.out.println("Subscriber 1 got you! The message is: "
                        + message.getStringProperty("content"));
            } catch (JMSException ex) {
                throw new RuntimeException(ex);
            }
        }
    }
}

在sender类中调用simpleSend()方法时，订阅此主题的所有侦听器都将异步获得此消息。但是我想知道这个特定的CustomerStatusListener是否从消息发送方接收消息。异步怎么做？我假设，如果我想异步地做的话，就不能像其中一个答案中建议的那样，在发送器和侦听器中使用replyto。我需要在sender和listener类中添加什么才能从listener获得消息接收确认？

Answer 1

我以前遇到过这样的情况。我使用了两个主题来处理这个场景。第一个主题用于发布，第二个主题用于回执。下面是我在应用程序中的流程。

1. 发件人向第一个主题发布“请求”邮件。
2. 侦听器在侦听消息 对象时接收消息。
3. 处理完消息后，侦听器将消息 对象发送到第二个主题。
4. 发送方依次监听消息 对象接收消息。我添加了关于侦听器的可识别信息，以找出哪些侦听器最终获得了我的请求消息 。

我希望它能解决你的问题。