JMS主题发布/订阅

Question

目前我已经开始使用ActiveMQ处理JMS主题。我通过JAVA代码（如下所示）创建了发布者和持久订阅者，并在订阅者端接收到了消息。

Publisher.Java

public static void createConnectionAndSendMessage(String ipAddress)
    {
        try
        {
            ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://"+ipAddress+":61617");

            Connection connection = factory.createConnection();
            connection.start();

            Session topicSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            Topic topic = topicSession.createTopic("Test-Topic");

            MessageProducer producer = topicSession.createProducer(topic);
            producer.setDeliveryMode(DeliveryMode.PERSISTENT);

            ObjectMessage message = topicSession.createObjectMessage();

            TopicTO topicTO = new TopicTO();
            topicTO.setId(i);
            topicTO.setName("Sample");

            message.setStringProperty("s_id", "Sample");
            message.setObject((Serializable) topicTO);                

            producer.send(message);
            System.out.println("message sent successfully");
        }
    }
    catch(JMSException e)
    {
        System.out.println("error :" + e);
    }
}

Subscriber.java

public void createConnectionAndReceiveMessage(String clientId, String ipAddress)
    {
        try
        {
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://"+ipAddress+":61617");
            Connection connection = connectionFactory.createConnection();
            connection.setClientID(clientId);
            connection.start();            
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            Topic topic = session.createTopic("Test-Topic");

            String selector = "s_id = 'Sample'";
            System.out.println("selector : '"+selector+"'....");
            TopicSubscriber consumer = session.createDurableSubscriber(topic, "Sub1", selector, true);

            consumer.setMessageListener(new TopicMessageListener());            

    }
    catch(Exception e)
    {
        System.out.println("error :" + e);
    }
}

我有一些关于主题的疑问，具体如下：

如何使用Java JMS检查有多少订阅者在主题中积极地查找消息？

如何从主题中获取这些活动持久订阅者的列表？

我们有没有选项可以删除发布在主题上的消息？

请帮助我解决这些问题。
提前致谢。

- Bhuvanesh Waran

Answer 1

在发布/订阅消息模式中，发布者将不知道任何订阅者。发布者将发布消息到代理托管的主题上，代理将随后将这些消息分发给已注册该主题的任何订阅者。如果没有订阅者，则消息将被简单地丢弃。

JMS规范未定义任何可以获取所需详细信息的API。这些API将是特定于JMS提供程序的，在您的情况下是Active MQ。这个链接可能会有用：http://activemq.apache.org/advisory-message.html

- Shashi