I add a filter plugin to set the expiration for the DLQ message, but seems
it doesn't work,
the message sent to DLQ still has not expiration.
@Override
public void sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription){
//set the expiration
messageReference.getMessage().setExpiration(60*60*1000);
this.next.sendToDeadLetterQueue(context, messageReference,
subscription);
}
--
View this message in context:
http://activemq.2283324.n4.nabble.com/remove-DLQ-message-tp4675686p4675868.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
