Skip to content

Commit 27f8b69

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

File tree

3 files changed

+3
-5
lines changed

3 files changed

+3
-5
lines changed

pkg/redis/RedisConsumer.php

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -42,9 +42,6 @@ public function getRedeliveryDelay(): ?int
4242
return $this->redeliveryDelay;
4343
}
4444

45-
/**
46-
* @param int $delay
47-
*/
4845
public function setRedeliveryDelay(int $delay): void
4946
{
5047
$this->redeliveryDelay = $delay;
@@ -103,7 +100,7 @@ public function reject(Message $message, bool $requeue = false): void
103100

104101
if ($requeue) {
105102
$message = $this->getContext()->getSerializer()->toMessage($message->getReservedKey());
106-
$message->setHeader('attempts', 0);
103+
$message->setRedelivered(true);
107104

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

pkg/redis/Tests/RedisConnectionFactoryConfigTest.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -268,7 +268,7 @@ public static function provideConfigs()
268268
yield [
269269
'rediss+phpredis://localhost:1234?foo=bar&async=1',
270270
[
271-
'host' => 'tls://localhost',
271+
'host' => 'localhost',
272272
'scheme' => 'rediss',
273273
'port' => 1234,
274274
'timeout' => 5.,

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)