消息和主题(持久化-非持久化)分类--持久化订阅
?
或者设置 producer.setDeliveryMode(DeliveryMode.PERSISTENT); //设置保存消息
然后再 connection.start();
?
?
?
2. 持久化订阅
?
默认情况下(使用ActiveMQ5.8.0版本默认配置启动代理) 使用publisher发送100个消息,如果发送消息时
消息发送完成之前,消费者没有启动,发送完成后再启动消息消费者,此时消费者不能接收消息.
因为消息已经发送过了.
?
使用持久化订阅可以让代理在消费者不在线时为消费者保存消息.当消费者上线了,可以再次接收并处理消息.
?
?
这时,消费者需要特殊处理,
首先在创建连接时要connection.setClientID("client-name"); 注册消费者.
然后MessageConsumer consumer = session.createDurableSubscriber(topic, "my-sub-name");
创建一个持久化订阅.
消费者创建好之后,要先运行一次,以便向消息代理注册消费者.
?
参考 :http://blog.chenlb.com/2010/01/jms-topic-durable-subscriber.html
?
?
?
?
?
?
?
?
?
?
?
?
?
