ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection =
connectionFactory.createConnection();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
connection.start();
Destination consumerTopicAdvisoryDest =
session.createTopic("ActiveMQ.Advisory.Consumer.Topic.>");
MessageConsumer consumerAdvisory =
session.createConsumer(consumerTopicAdvisoryDest);
consumerAdvisory.setMessageListener(listener);
=> result two subscriber are running:
A consumer subscribed to a topic or queue: ConsumerInfo {commandId = 4,
consumerId = ID:QuangDe-PC-51000-1397993623150-1:1:1:1, destination =
topic://TOPIC2 }
A consumer subscribed to a topic or queue: ConsumerInfo {commandId = 4,
consumerId = ID:QuangDe-PC-54005-1398005456464-1:1:1:1, destination =
topic://TOPIC1}
But when I change
Destination consumerTopicAdvisoryDest =
session.createTopic("ActiveMQ.Advisory.>");
=> result:
ActiveMQMessage {commandId = 0, messageId =
ID:QuangDe-PC-49713-1397991439530-1:1:0:0:1, producerId =
ID:QuangDe-PC-49713-1397991439530-1:1:0:0, destination =
topic://ActiveMQ.Advisory.MasterBroker}
I WANT TO ASK: Why topic "ActiveMQ.Advisory.>" not include two subscribers
are running???
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Why-advisory-topic-ActiveMQ-Advisory-can-not-query-subscribed-tp4680422.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
