Validate message status (Success or Failure)

[sravindran2020]

Hello,

I'm writing integration tests for my application. My application queues a message with Rqueue. Is there a recommended way to validate the status of a queued message?

Trying to validate in my integration test that the status of a queued message is either a success or failure. Any insights or suggestions would be useful.

What I tried thus far:
Tried to obtain the JOB param from message headers of an RqueueMessage and inspect the JobStatus. But looks like the message headers always returns null.

[sonus21]

• When you enqueue message using RqueueMessageEnqueuer it returns true/false.
• You can use RqueueMessageManager#exist method(s) to check whether the given message id exist or not
• If you don't have message id, you can read all message and check whether the given message exist or not.

[sravindran2020]

Thank you for your response. I already do read all messages to check whether a given message exists. However, I am trying to ascertain whether or not the queued message was successfully processed. Is there a way to achieve this?

[sonus21]

What do you mean by queued message was successfully processed? Are you trying to validate whether the said message was consumed correctly or not?

If you're trying to check message status post consumption you can read message metadata from redis and check it's status. It's status would be changed.

[sravindran2020]

Yes, that is what I meant - "whether the said message was consumed correctly". In my tests, I noticed that if the message is successfully consumed, it gets removed from the queue. So I presume the only time the message is present in the queue, is when it was not consumed (due to errors in the listener/receiver of the message)?

[sravindran2020]

Also, could you point me to the right API method to use in order to obtain the metadata? I see that the com.github.sonus21.rqueue.core.Job class has MessageMetadata. But I was not able to get a handle to the Job class via the RqueueMessage's MessageHeaders property. Because MessageHeaders always appears to be null.

[sonus21]

rqueue/rqueue-core/src/main/java/com/github/sonus21/rqueue/web/service/RqueueMessageMetadataService.java

Line 38 in 6a775f3

MessageMetadata getByMessageId(String queueName, String messageId);