我正在使用activeMQ进行消息传递。当发送者和接收者都可用时,我成功接收到该消息。但是当我按下接收器并重新启动时,排队的消息不会再次接收到接收器。我需要做任何配置吗? 我增加了如下的生活时间,以避免会话到期。
这是我的发件人代码的样子。
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createTopic(topic);
MessageProducer producer = session.createProducer(destination);
producer.setTimeToLive(18000000L);
TextMessage message = session.createTextMessage(customMessage.getcontent());
producer.send(message);