Есть ли способ подавления дублированных сообщений в очереди, определенной на сервере ActiveMQ?
Я попытался определить JMSMessageID вручную (message.setJMSMessageID("uniqueid")), но сервер игнорирует эту модификацию и доставляет сообщение со встроенным сгенерированным JMSMessageID.
По спецификации я не нашел ссылки о том, как дедуплицировать сообщения.
В HornetQ, чтобы справиться с этой проблемой, нам нужно объявить специальное свойство HQ org.hornetq.core.message.impl.HDR_DUPLICATE_DETECTION_ID при определении сообщения.
то есть:
Message jmsMessage = session.createMessage();
String myUniqueID = "This is my unique id"; // Could use a UUID for this
message.setStringProperty(HDR_DUPLICATE_DETECTION_ID.toString(), myUniqueID);
Кто-нибудь знает, есть ли подобное решение для ActiveMQ?