在 producer 生產者 中需要設定

      producer.setDeliveryMode(DeliveryMode.PERSISTENT);//            producer.setTimeToLive(10);
//            傳送
producer.send(textMessage);
//            producer.send(textMessage, DeliveryMode.PERSISTENT, 1, 60 * 60 * 24);
 

//設定客戶端id
connection.setClientID("client-1");

connection.start();

//            final MessageConsumer messageConsumer = session.createConsumer(topic);//普通訂閱
MessageConsumer messageConsumer = session.createDurableSubscriber(topic,"bb"); //持久訂閱

程式碼：

import org.apache.activemq.ActiveMQConnection;
 
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
 * @author Yang
 * @create 2018-04-19 17:11
 * 描述： 生產者
*/
public class TopicProducer {

    /**
     * 使用者名稱
*/
private static final String userName = ActiveMQConnection.DEFAULT_USER;
/**
     * 密碼
*/
private static final String passWord = ActiveMQConnection.DEFAULT_PASSWORD;
/**
     * url
     */
private static final String brokerUrl = ActiveMQConnection.DEFAULT_BROKER_URL;
    public void send(String message) {


        try {
            ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(userName, passWord, brokerUrl);
            final Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
//建立佇列
final Topic topic = session.createTopic("topic");
            final MessageProducer producer = session.createProducer(topic);
TextMessage textMessage = session.createTextMessage(message);
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
//            producer.setTimeToLive(10);
//            傳送
producer.send(textMessage);
//            producer.send(textMessage, DeliveryMode.PERSISTENT, 1, 60 * 60 * 24);
//            session.commit();
producer.close();

session.close();
connection.close();
} catch (JMSException e) {
            e.printStackTrace();
}

    }

    public static void main(String[] args) {
        TopicProducer producer = new TopicProducer();
producer.send("hello world");
}


}

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
 * @author Yang
 * @create 2018-04-19 17:10
 * 描述： 消費者
*/
public class TopicConsumer {

    /**
     * 使用者名稱
*/
private static final String userName = ActiveMQConnection.DEFAULT_USER;
/**
     * 密碼
*/
private static final String passWord = ActiveMQConnection.DEFAULT_PASSWORD;
/**
     * url
     */
private static final String brokerUrl = ActiveMQConnection.DEFAULT_BROKER_URL;
    public void receive() {


        try {
            ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(userName, passWord, brokerUrl);
            final Connection connection = connectionFactory.createConnection();
//設定客戶端id
connection.setClientID("client-1");
connection.start();
Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
//建立佇列
final Topic topic = session.createTopic("topic");
//            final MessageConsumer messageConsumer = session.createConsumer(topic);//普通訂閱
MessageConsumer messageConsumer = session.createDurableSubscriber(topic,"bb"); //持久訂閱
messageConsumer.setMessageListener(n -> {

                try {
                    TextMessage msg = (TextMessage) n;
                    final String text = msg.getText();
                    if (text.equalsIgnoreCase("hello world")) {
                        System.out.println("               接受資訊：         " + msg.getText());
} else {
                        System.out.println("     測試重發次數 ");
                        int i = 1 / 0;
}


                } catch (JMSException e) {
//                    e.printStackTrace();
}

            });
} catch (JMSException e) {
//            e.printStackTrace();
}

    }

    public static void main(String[] args) {
        TopicConsumer consumer = new TopicConsumer();
consumer.receive();
}


}