ActiveMQ JMS API中的追溯消费者

Question

我正在研究ActiveMQ，看看它是否适用于一个项目。我需要展示的当前用例是，晚加入的订阅者将收到在创建订阅之前发布的主题。看起来ActiveMQ追溯消费者将满足这一需求，但我无法让代码工作。

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("[url]");
Connection connection = connectionFactory.createConnection();
connection.start();

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

Destination destination = session.createTopic("testAddress?consumer.retroactive=true");

MessageProducer producer = session.createProducer(destination);

TextMessage message = session.createTextMessage("Hello, World!");

producer.send(message);

Thread.sleep(5000);

session.createConsumer(destination).setMessageListener(message2 -> processMessage(message2));

session.close();
connection.close();
connectionFactory.close();

我在这里试图证明的是，一个主题可以被发布，然后在一段任意的时间后（例如。5秒），消费者可以订阅该主题并接收前一条消息。

据我所知，问题似乎是创建主题会创建一个地址，但不会创建任何关联的队列。如果我在队列形成之前将主题发送到该地址（无论是通过代码还是通过代理的网络接口手动发送），消息似乎会被忽略，“未路由消息计数”会立即增加。

ActiveMQ留档（https://activemq.apache.org/retroactive-consumer）在制作主题时没有提供比附加“？consumer.retroactive=true”更详细的关于如何设置追溯消费者的信息，所以我想知道我是否遗漏了其他一些配置方面。

Answer 1

为了在ActiveMQ Artemis中实现所需的行为（订阅者接收订阅之前发布的主题），我使用了一个具有非破坏性读取的最后值队列。这有一个限制，我只收到一个主题发布的最新副本，但这将适合我的情况。

Answer 2

据我所知，ActiveMQ Artemis不支持5. x的追溯消费者功能。客户端选项只是告诉代理你想要它，但是由于Artemis不处理它，你看不出发送它有什么不同。5. x中的功能本身不应该作为持久消费者的100%替代品，例如代理重启会导致所有这些消息（其中存储的数量是有限的）丢失。

如果您想保证在主题消费者离线时收到发送的消息，那么持久消费者是安全的方法