zoukankan      html  css  js  c++  java
  • activemq 使用

    // 创建connection
    connection = connectionFactory.createConnection();
    connection.setClientID("bbb"); //持久订阅需要设置这个。
    connection.start();
    
    // 创建session
    Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
    
    // 创建destination
    Topic topic = session.createTopic("userSyncTopic"); //Topic名称
    
    //MessageConsumer consumer = session.createConsumer(topic); //普通订阅
    MessageConsumer consumer = session.createDurableSubscriber(topic,"bbb"); //持久订阅

    (5)使用相同的“clientID”,则认为是同一个消费者。两个程序使用相同的“clientID”,则同时只能有一个连接到activemq,第二个连接的会报错。

    (6)activemq的设置在conf/activemq.xml中,默认消息是保存在data/kahadb中,重启activemq消息不会丢。

  • 相关阅读:
    抽象工厂模式
    观察者模式
    建造者模式
    外观模式
    drf 之路由
    drf之视图
    drf--请求和响应
    def--序列化
    drf之restful规范
    Tepora使用
  • 原文地址:https://www.cnblogs.com/empireghost/p/5330306.html
Copyright © 2011-2022 走看看