Skip to content

Commit 01e35cd

Browse files
committed
Fix $deliveryAt in RedisProducer::send by converting deliveryDelay milliseconds to seconds
1 parent 9f15659 commit 01e35cd

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Diff for: pkg/redis/RedisProducer.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ public function send(Destination $destination, Message $message): void
6464
$payload = $this->context->getSerializer()->toString($message);
6565

6666
if ($message->getDeliveryDelay()) {
67-
$deliveryAt = time() + $message->getDeliveryDelay();
67+
$deliveryAt = time() + $message->getDeliveryDelay() / 1000;
6868
$this->context->getRedis()->zadd($destination->getName().':delayed', $payload, $deliveryAt);
6969
} else {
7070
$this->context->getRedis()->lpush($destination->getName(), $payload);

0 commit comments

Comments
 (0)