I read the doc about the DMQ-eligibility:
- for AMQP 1.0, every message is set to DMQ Eligible
- for the JMS API, refer to : JMS API
So here’s the producer code:
jmsTemplate.convertAndSend(jmsDestination, message, new MessagePostProcessor() {
@Override
public Message postProcessMessage(Message message) throws JMSException {
message.setBooleanProperty("SOLACE_JMS_PROP_DEAD_MSG_QUEUE_ELIGIBLE", true);
return message;
}
});
I did try to set a TTL on the Queue Im sending messages to and they’re properly redirected to the DMQ