diff --git a/libs/micronaut-worker/src/main/java/com/agorapulse/worker/queue/QueueMessage.java b/libs/micronaut-worker/src/main/java/com/agorapulse/worker/queue/QueueMessage.java index 4234bb1e..23b4c2c9 100644 --- a/libs/micronaut-worker/src/main/java/com/agorapulse/worker/queue/QueueMessage.java +++ b/libs/micronaut-worker/src/main/java/com/agorapulse/worker/queue/QueueMessage.java @@ -47,8 +47,20 @@ static QueueMessage requeueIfDeleted(T message, Runnable doDelete, Runnab return DefaultQueueMessage.requeueIfDeleted(message, doDelete, doRequeue); } + /** + * Returns the payload of the message. + * @return the payload of the message + */ T getMessage(); + + /** + * Deletes the message from the queue. + */ void delete(); + + /** + * Requeues the message. Depending on the type of the message it might not be requeued if it was not deleted. + */ void requeue(); }