非共享非持久化订阅
非共享持久化订阅
大话文来讲,就是订阅了某主题后,订阅者就算宕机了,下次启动后,还能收到宕机前的数据。
实现非共享持久化订阅者只需要加
// 通过conn对象,持久订阅需指定ClientId
conn.setClientID("client-1");
// 5、创建消息消费者 http://activemq.apache.org/destination-options.html
TopicSubscriber consumer = session.createDurableSubscriber(destination, "my name");
网友评论