zoukankan      html  css  js  c++  java
  • JMS-activeMq发布订阅模式

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

      代码如下:

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

      

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

      

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

      

  • 相关阅读:
    Smarty数学运算
    双引号里值的嵌入
    Smarty属性
    Smarty函数
    Smarty注释代码
    数据结构实验2——链表
    数据结构实验1——顺序表
    hdu 5459 Jesus Is Here
    hdu 5455 Fang Fang
    2018 多校6 hdu 6362 6370 6373
  • 原文地址:https://www.cnblogs.com/gdpuzxs/p/6618832.html
Copyright © 2011-2022 走看看