Apache ActiveMQ 5.3 - Как настроить очередь для отклонения повторяющихся сообщений?
Мне нужна очередь для обеспечения политики без дубликатов. Является ли это возможным? Если да, то как? (Я гуглил в течение нескольких часов ...)
Редактировать:
Реализация ActiveMQSession имеет следующие строки:
// transform to our own message format here
ActiveMQMessage msg = ActiveMQMessageTransformation.transformMessage(message, connection);
// Set the message id.
if (msg == message) {
msg.setMessageId(new MessageId(producer.getProducerInfo().getProducerId(), sequenceNumber));
} else {
msg.setMessageId(new MessageId(producer.getProducerInfo().getProducerId(), sequenceNumber));
message.setJMSMessageID(msg.getMessageId().toString());
}
ActiveMQMessageTransformation является подключаемым (вы можете установить его), но следующий оператор if довольно неопровержим.
Любые идеи, кроме изменения их кода?