Skip to content

Commit 01e35cd

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

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

‎pkg/redis/RedisProducer.php‎

Lines changed: 1 addition & 1 deletion
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)