java JMSTemplate检查主题是否存在并获取订户计数
我一直在寻找一些文档/示例,用于检查动态创建的主题是否存在,如果存在,如何获取该主题的订户数量
我使用以下代码向主题发送消息-
jmsTemplate.send(destination, new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
TextMessage message = session.createTextMessage();
message.setText(commandStr);
return message;
}
});
这段代码似乎创建了主题并将消息发布到主题
- 在创建主题之前,我需要检查主题是否存在李>
- 检查主题是否有订户李>
提前谢谢
我找到了(1)问题的解决办法(希望这有帮助)-
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
ActiveMQConnection connection = (ActiveMQConnection)connectionFactory.createConnection();
connection.start();
DestinationSource ds = connection.getDestinationSource();
Set<ActiveMQTopic> topics = ds.getTopics();
# 1 楼答案
要获取目的地名称,正如您所做的那样,这是正确的,您可以通过JMX来获取统计信息,例如订户计数
或
更新
您可以使用
AdvisorySupport.getConsumerAdvisoryTopic()