JMS-activeMq发布订阅模式

　　上一篇对点对点模式进行总结，这一篇都发布订阅模式进行总结，代码都差不多，唯一区别就是创建队（session.createQueue(目的地)）列改为创建主题（session.createTopic(目的地)）。

　　代码如下：

　　发布订阅模式-生产者类HelloTopicProducer

　　


　　发布订阅模式-生产者类HelloTopicConsumer

　　


　　代码结束，本地测试的时候，先启动消费者代码（先订阅再收消息），然后再启动生产者代码。生产者和消费者类分别启动两个环境进行运行（启动两个eclipse）,因为在同一个环境下运行，生产者和消费者不能同时在线，这样会导致生产者生产消息，actimeMq控制台已经收到消息，但是消费者一直读取不到消息。