Skip to content

Commit 385d00e

Browse files
committed
fix(MongoDB) Redelivery not working (fixes #1077)
1 parent f49955c commit 385d00e

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

MongodbConsumer.php

+1
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,7 @@ public function reject(Message $message, bool $requeue = false): void
109109
InvalidMessageException::assertMessageInstanceOf($message, MongodbMessage::class);
110110

111111
if ($requeue) {
112+
$message->setRedelivered(true);
112113
$this->context->createProducer()->send($this->queue, $message);
113114

114115
return;

0 commit comments

Comments
 (0)