Can you add a sample for Dead Letter Queue Scenario about rqueue HOT 6 CLOSED

To Summarize, the dead messages are not reaching their listener method

This is little bit confusing to me, this is the expected behaviour not? When a message reaches it's retry limit than your listener method won't be called.

Let me know if I have misunderstood anything.

See this test
https://github.com/sonus21/rqueue/blob/master/rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/tests/integration/ApplicationTest.java#L48

from rqueue.

Yes, the expected behavior is, once the retry limit is reached, the message to be discarded.
But when a dead letter queue is configured for this, the message should not be just discarded,
it should be moved to its dead letter queue.

Currently it is not happening.

@RqueueListener(value = "delay-queue", numRetries = "1", deadLetterQueue = "dead-queue", concurrency = "10-100")
public void delayMessage(Message message) {
log.info("Message received for delay :: {}", message);
}

@RqueueListener(value = "dead-queue", numRetries = "1", deadLetterQueue = "", concurrency = "5")
public void delayMessage(Message message) {
log.info("Dead Message from delay-queue :: {}", message);
}

After failure count = 1 in delay-queue listener
Message should be enqueued in dead-queue

But its is just discarded, not moved to dead-queue

Please test and confirm

from rqueue.

Hmm, this is not supported. Messages are moved to dead letter queue but they can not be consumed using other listener.

from rqueue.

Thanks

For now, is there a way to process dead messages.
e.g : Sending a mail saying "A message died in delay-queue"

from rqueue.

yes, that can be done. you can register dead letter callback handler that can do whatever you want,
See wiki
https://github.com/sonus21/rqueue/wiki/Callback-Events

For your case, I think it would be more appropriate to use Discard Execution processor, as this can trigger email as well as re-enqueue. You can find the queue name from the RqueueMessage object.

https://github.com/sonus21/rqueue/wiki/Callback-Events#discard-execution-processor

from rqueue.

HI Karthik,
If you're still looking for this feature than you can use the latest release 2.0.4-RELEASE.

https://github.com/sonus21/rqueue/wiki/Producer-Consumer#dead-letter-queue-consumerlistener

Open this bug if you need any more details.

from rqueue.