symfony
diff --git a/‎src/Symfony/Component/Messenger/Transport/RedisExt/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/RedisExt/Connection.php
+4-4Lines changed: 4 additions & 4 deletions b/‎src/Symfony/Component/Messenger/Transport/RedisExt/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/RedisExt/Connection.php
+4-4Lines changed: 4 additions & 4 deletions
diff --git a/‎src/Symfony/Component/Messenger/Transport/RedisExt/RedisSender.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/RedisExt/RedisSender.php
+1-1Lines changed: 1 addition & 1 deletion b/‎src/Symfony/Component/Messenger/Transport/RedisExt/RedisSender.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/RedisExt/RedisSender.php
+1-1Lines changed: 1 addition & 1 deletion
@@ -233,7 +233,7 @@ public function reject(string $id): void
         }
     }
 
-    public function add(string $body, array $headers, int $delayInMs = 0): void
+    public function add(string $body, array $headers, float $delayInMs = 0): void
     {
         if ($this->autoSetup) {
             $this->setup();
@@ -252,7 +252,7 @@ public function add(string $body, array $headers, int $delayInMs = 0): void
                     throw new TransportException(json_last_error_msg());
                 }
 
-                $score = (int) ($this->getCurrentTimeInMilliseconds() + $delayInMs);
+                $score = $this->getCurrentTimeInMilliseconds() + (float) $delayInMs;
                 $added = $this->connection->zadd($this->queue, ['NX'], $score, $message);
             } else {
                 $message = json_encode([
@@ -301,9 +301,9 @@ public function setup(): void
         $this->autoSetup = false;
     }
 
-    private function getCurrentTimeInMilliseconds(): int
+    private function getCurrentTimeInMilliseconds(): float
     {
-        return (int) (microtime(true) * 1000);
+        return microtime(true) * (float) 1000;
     }
 
     public function cleanup(): void
 
@@ -42,7 +42,7 @@ public function send(Envelope $envelope): Envelope
         $delayStamp = $envelope->last(DelayStamp::class);
         $delayInMs = null !== $delayStamp ? $delayStamp->getDelay() : 0;
 
-        $this->connection->add($encodedMessage['body'], $encodedMessage['headers'] ?? [], $delayInMs);
+        $this->connection->add($encodedMessage['body'], $encodedMessage['headers'] ?? [], (float) $delayInMs);
 
         return $envelope;
     }
Original file line number	Diff line number	Diff line change
`@@ -233,7 +233,7 @@ public function reject(string $id): void`
`233`	`233`	`}`
`234`	`234`	`}`
`235`	`235`
`236`		`- public function add(string $body, array $headers, int $delayInMs = 0): void`
	`236`	`+ public function add(string $body, array $headers, float $delayInMs = 0): void`
`237`	`237`	`{`
`238`	`238`	`if ($this->autoSetup) {`
`239`	`239`	`$this->setup();`
`@@ -252,7 +252,7 @@ public function add(string $body, array $headers, int $delayInMs = 0): void`
`252`	`252`	`throw new TransportException(json_last_error_msg());`
`253`	`253`	`}`
`254`	`254`
`255`		`- $score = (int) ($this->getCurrentTimeInMilliseconds() + $delayInMs);`
	`255`	`+ $score = $this->getCurrentTimeInMilliseconds() + (float) $delayInMs;`
`256`	`256`	`$added = $this->connection->zadd($this->queue, ['NX'], $score, $message);`
`257`	`257`	`} else {`
`258`	`258`	`$message = json_encode([`
`@@ -301,9 +301,9 @@ public function setup(): void`
`301`	`301`	`$this->autoSetup = false;`
`302`	`302`	`}`
`303`	`303`
`304`		`- private function getCurrentTimeInMilliseconds(): int`
	`304`	`+ private function getCurrentTimeInMilliseconds(): float`
`305`	`305`	`{`
`306`		`- return (int) (microtime(true) * 1000);`
	`306`	`+ return microtime(true) * (float) 1000;`
`307`	`307`	`}`
`308`	`308`
`309`	`309`	`public function cleanup(): void`
Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,7 @@ public function send(Envelope $envelope): Envelope`
`42`	`42`	`$delayStamp = $envelope->last(DelayStamp::class);`
`43`	`43`	`$delayInMs = null !== $delayStamp ? $delayStamp->getDelay() : 0;`
`44`	`44`
`45`		`- $this->connection->add($encodedMessage['body'], $encodedMessage['headers'] ?? [], $delayInMs);`
	`45`	`+ $this->connection->add($encodedMessage['body'], $encodedMessage['headers'] ?? [], (float) $delayInMs);`
`46`	`46`
`47`	`47`	`return $envelope;`
`48`	`48`	`}`