我使用的是 ActiveMQ Artemis 2.10,在我的用例中,我希望避免队列中出现重复的消息,因此我在向队列发送消息之前设置了属性 Message.HDR_DUPLICATE_DETECTION_ID:
ClientConsumer consumer = session.createConsumer(queueName);
ClientMessage message = consumer.receive();
message.putStringProperty(Message.HDR_DUPLICATE_DETECTION_ID, hashVal);
但问题是,即使在这条消息被消耗之后,如果我尝试发送另一条具有相同 hashVal 值的消息,新消息也会被拒绝。即使队列中没有其他具有相同 hashVal 值的消息。
有没有办法设置重复检测,仅当队列中存在具有相同 HDR_DUPLICATE_DETECTION_ID 的未消费消息时才拒绝消息?
最佳答案
您所看到的行为是预期的。每条消息的重复检测 ID 应该是唯一的。如果您对多条消息使用相同的 ID,并且尚未清除代理上的重复 ID 缓存,则该消息可能会被拒绝。根据缓存的大小从缓存中逐出 ID。一旦缓存达到其配置的大小,它将在添加新 ID 时开始删除最旧的 ID。
关于java - ActiveMQ Artemis 中的消息重复在消息被消费后仍然被拒绝,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59002142/