我正在学习如何使用ActiveMQ，现在我们面临以下问题。
假设我在 ActiveMQ 上有一个名为 topic.test 的主题，它有两个订阅者。
在特定时刻，我只有一个订阅者在等待消息，而生产者则为我上面提到的主题发送一条消息。
好的，连接的订阅者收到了消息，但是其他订阅者在连接后不应该收到该消息吗？好吧，就我而言，这并没有发生：我的订阅者仅在连接时接收消息。他们不会收到在未连接时发送的所有其他消息。我可能做错了什么？
这是我为测试 ActiveMQ 编写的一些源代码。也许你能发现它出了什么问题。
我的消费者代码：
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
connection.setClientID("leitorTeste");
conexao.start();
Session sessao = conexao.createSession(false, Session.AUTO_ACKNOWLEDGE);
Topic fonte = sessao.createTopic("topic.test");
MessageConsumer consumer = sessao.createConsumer(fonte);
javax.jms.Message presente = null;
while ((presente = consumer.receive()) != null) {
System.out.println(((TextMessage) presente).getText());
}
consumer.setMessageListener(new LeitorMensagens());
conexao.close();
这是我的生产者代码：
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
Session sessao = conexao.createSession(true, Session.AUTO_ACKNOWLEDGE);
connection.start();
Destination destino = sessao.createTopic("topic.test");
MessageProducer produtorMensagem = sessao.createProducer(destino);
produtorMensagem.setDeliveryMode(DeliveryMode.PERSISTENT);
TextMessage message = sessao.createTextMessage("Hi!");
produtorMensagem.send(message);
sessao.commit();
connection.close();
我是否应该向 ActiveMQ 添加任何其他配置，以便我的消费者可以获得较旧的消息？
你必须让你的消费者“永久”。否则，一旦他们取消订阅，AMQ 就会“忘记”他们。为此，请使用Session.createDurableSubscriber() http://java.sun.com/j2ee/1.4/docs/api/javax/jms/Session.html#createDurableSubscriber%28javax.jms.Topic,%20java.lang.String%29
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
