Skip to content

Commit b17b356

Browse files
fix: do not reset attemps header when message is requeue
1 parent 261409d commit b17b356

File tree

2 files changed

+1
-1
lines changed

2 files changed

+1
-1
lines changed

pkg/redis/RedisConsumer.php

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,6 @@ public function reject(Message $message, bool $requeue = false): void
103103

104104
if ($requeue) {
105105
$message = $this->getContext()->getSerializer()->toMessage($message->getReservedKey());
106-
$message->setHeader('attempts', 0);
107106

108107
if ($message->getTimeToLive()) {
109108
$message->setHeader('expires_at', time() + $message->getTimeToLive());

pkg/redis/Tests/RedisConsumerTest.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,7 @@ public function testShouldSendSameMessageToDestinationOnReQueue()
112112

113113
$message = new RedisMessage();
114114
$message->setBody('text');
115+
$message->setHeader('attempts', 0);
115116
$message->setReservedKey($serializer->toString($message));
116117

117118
$consumer = new RedisConsumer($contextMock, new RedisDestination('aQueue'));

0 commit comments

Comments
 (0)