我看servicemix的源代码中jmsflow对象有如下代码在init方法中有如下的代码
//init()
....
broadcastSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
broadcastTopic = broadcastSession.createTopic(broadcastDestinationName);
topicProducer = broadcastSession.createProducer(broadcastTopic); topicProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
....在该对象的start方法中有如下的代码
//start()
....
Topic advisoryTopic = AdvisorySupport.getConsumerAdvisoryTopic((ActiveMQDestination) broadcastTopic);
advisoryConsumer = broadcastSession.createConsumer(advisoryTopic);
advisoryConsumer.setMessageListener(new MessageListener() {
public void onMessage(Message message) {
if (started.get()) {
onAdvisoryMessage(((ActiveMQMessage) message).getDataStructure());
}
}
});
...
...请问:broadcastTopic和advisoryTopic 有什么关系?当有消息发到broadcastTopic对advisoryTopic 有没有影响
//init()
....
broadcastSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
broadcastTopic = broadcastSession.createTopic(broadcastDestinationName);
topicProducer = broadcastSession.createProducer(broadcastTopic); topicProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
....在该对象的start方法中有如下的代码
//start()
....
Topic advisoryTopic = AdvisorySupport.getConsumerAdvisoryTopic((ActiveMQDestination) broadcastTopic);
advisoryConsumer = broadcastSession.createConsumer(advisoryTopic);
advisoryConsumer.setMessageListener(new MessageListener() {
public void onMessage(Message message) {
if (started.get()) {
onAdvisoryMessage(((ActiveMQMessage) message).getDataStructure());
}
}
});
...
...请问:broadcastTopic和advisoryTopic 有什么关系?当有消息发到broadcastTopic对advisoryTopic 有没有影响
解决方案 »
免费领取超大流量手机卡,每月29元包185G流量+100分钟通话, 中国电信官方发货