ActiveMQ 持久化订阅

1. 第一步

   TopicPublisher publisher = session.createPublisher(topic);
   //设置订阅模式为持久化
   publisher.setDeliveryMode(DeliveryMode.PERSISTENT);
   //设置持久化时间，默认为永不过期，方法参数为毫秒
   publisher.setTimeToLive(60000);
   

    
2. 第二步

   TopicConnection topicConnection = factory.createTopicConnection();
   //设置订阅者的ID，以后再用这个身份的话再连接的话，会将此ID没有接收到的消息接收下来（也就是离线消息）
   topicConnection.setClientID("topic");
   //创建持久化订阅对象
   TopicSubscriber subscriber = session.createDurableSubscriber(topic, "topic");

    
3. 第三步：可以运行了