Apache ActiveMQ 5.3 - Como configurar uma fila para rejeitar mensagens duplicadas?
Eu preciso da fila para impor a política não duplicada. É possível? Se sim, como? (Eu estive pesquisando por horas ...)
Editar:
A implementação do ActiveMQSession possui estas linhas:
// 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());
}
O ActiveMQMessageTransformation é plugável (você pode configurá-lo), mas a instrução if a seguir é um pouco incontroversa.
Alguma idéia, exceto mudar seu código?