и значение свойства

ли способ подавления дублирующихся сообщений в очереди, определенной на сервере 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?

Ответы на вопрос(5)

Ваш ответ на вопрос