Topic消息接收

2019-10-21  本文已影响0人  长孙俊明

非共享非持久化订阅

非共享持久化订阅

大话文来讲,就是订阅了某主题后,订阅者就算宕机了,下次启动后,还能收到宕机前的数据。
实现非共享持久化订阅者只需要加

// 通过conn对象,持久订阅需指定ClientId
conn.setClientID("client-1");
// 5、创建消息消费者 http://activemq.apache.org/destination-options.html
TopicSubscriber consumer = session.createDurableSubscriber(destination, "my name");

共享非持久化订阅

共享持久化订阅

目的是为了解决高并发同一个主题下,消费者无法及时消费主题信息问题。

上一篇 下一篇

猜你喜欢

热点阅读