We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8ec9506 commit 8f44320Copy full SHA for 8f44320
1 file changed
pkg/mongodb/MongodbConsumer.php
@@ -109,6 +109,7 @@ public function reject(Message $message, bool $requeue = false): void
109
InvalidMessageException::assertMessageInstanceOf($message, MongodbMessage::class);
110
111
if ($requeue) {
112
+ $message->setRedelivered(true);
113
$this->context->createProducer()->send($this->queue, $message);
114
115
return;
0 commit comments