Procedure for immediate deletion of message from queue.

[Prachil-MI]

What's not working?

Used following method to delete a message from queue.

rqueueMessageManager.deleteMessage(Queue.DATA_SOURCE_PROCESSING, QUEUE_PRIORITY_LOW,
                    processingLogId);

The message is marked as deleted. But it is not removed immediately. I am assuming that this is the intended behaviour.

Questions:

1. What are the steps to achieve its immediate deletion?
2. If there is no way as of now, can it be achieved via following method? If yes, what are the steps? How the object name and metadata are constructed?

// factory is an instance of `SimpleRqueueListenerContainerFactory`
factory.setManualDeletionMessageProcessor()

3. If above two methods are not the correct choice, are there any alternatives?

What're application dependencies ?

• Rqueue Spring Boot Starter Version: 3.1.1-RELEASE
• Spring Boot Version: 6.1.8
• Spring Messaging Version: 6.1.8
• Spring Data Redis Version: 3.3.0 Other libraries are not relevant.

How to Reproduce (optional)?

• To reproduce, implement the given method.

Additional Details (optional)

Make sure to use priority while enqueueing the message.

[sonus21]

@Prachil-MI , if you call a message to be deleted, its deleted it should not be consumed by the application in anyway. Are you observing a different behaviour?

[Prachil-MI]

@sonus21 Correct. That is the expected behaviour. The application does not use the message in any way. But the message is held in Redis for 30 minutes. The metadata and the message has a field deleted: true.

Since the message stays in Redis for 30 minutes, the Redis memory is not usable during that period of time.

[sonus21]

@Prachil-MI do you've a usecase where you delete large number of messages in short duration? I expected this feature to be used once in a while or on rare occasions.

[Prachil-MI]

@sonus21 do you've a usecase where you delete large number of messages in short duration? Correct. That is the exact use case that I have. I expected this feature to be used once in a while or on rare occasions. Based on the current implementation, are there any alternatives?

[sonus21]

currently there's no way, but if you want to reduce the Redis memory usage, you can set these properties

• rqueue.message.durability.in-terminal-state = 0
• rqueue.job.enabled = false

[Prachil-MI]

Ok. I will try. Thank you very much for your help! Closing the ticket.