rqueue icon indicating copy to clipboard operation
rqueue copied to clipboard

lockKey as plain messageId without lock prefix while consuming a message.

Open ilya-mak opened this issue 1 year ago • 1 comments

Hi,

After sending successfully a message to redis using RqueueMessageEnqueuer.enqueue(queueName, message), I'm consuming a messeage using @RqueueListener(value = "my-queue") annotation and while debugging i can see that while processing a message rqueue is updating the message status(message metaData) and its using a lockKey for the setNX command as plain messageId without the lockKey prefix ("__rq::lock::").

I saw there is a getLockKeyPrefix(String key) method in RqueueConfig class but its not being used through this process.

Is this behavior is normal and intended?

Is there a way to override/configure a lockKey prefix default or custom instead only a messageId, to use through a simple message consuming process I mentioned above?

  • Rqueue Version: 2.13.0-RELEASE
  • Spring Boot Version: 2.7.5

Thank you.

lockKeyInit setIfAbsent

ilya-mak avatar Sep 15 '24 01:09 ilya-mak

This looks like an issue to me, let me investigate this more.

sonus21 avatar Oct 22 '24 17:10 sonus21

This has been fixed by #248

sonus21 avatar Jun 29 '25 16:06 sonus21