From 99aae50d516ad4d14b3d5c6e551c5e8ad1dae80f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Igor=20Planta=C5=A1?= <igor.plantas@sofascore.com>
Date: Tue, 10 Dec 2024 15:49:24 +0100
Subject: [PATCH] [BeanstalkMessenger] Round delay to an integer to avoid
 deprecation warning

---
 .../Tests/Transport/ConnectionTest.php        | 21 +++++++++++++++++++
 .../Beanstalkd/Transport/Connection.php       |  2 +-
 2 files changed, 22 insertions(+), 1 deletion(-)

diff --git a/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Tests/Transport/ConnectionTest.php b/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Tests/Transport/ConnectionTest.php
index f4cc745846584..bf54ac1272483 100644
--- a/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Tests/Transport/ConnectionTest.php
+++ b/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Tests/Transport/ConnectionTest.php
@@ -330,4 +330,25 @@ public function testSendWhenABeanstalkdExceptionOccurs()
 
         $connection->send($body, $headers, $delay);
     }
+
+    public function testSendWithRoundedDelay()
+    {
+        $tube = 'xyz';
+        $body = 'foo';
+        $headers = ['test' => 'bar'];
+        $delay = 920;
+        $expectedDelay = 0;
+
+        $client = $this->createMock(PheanstalkInterface::class);
+        $client->expects($this->once())->method('useTube')->with($tube)->willReturn($client);
+        $client->expects($this->once())->method('put')->with(
+            $this->anything(),
+            $this->anything(),
+            $expectedDelay,
+            $this->anything(),
+        );
+
+        $connection = new Connection(['tube_name' => $tube], $client);
+        $connection->send($body, $headers, $delay);
+    }
 }
diff --git a/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Transport/Connection.php b/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Transport/Connection.php
index 98ab37c875d18..ff520ddb3071f 100644
--- a/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Transport/Connection.php
+++ b/src/Symfony/Component/Messenger/Bridge/Beanstalkd/Transport/Connection.php
@@ -123,7 +123,7 @@ public function send(string $body, array $headers, int $delay = 0): string
             $job = $this->client->useTube($this->tube)->put(
                 $message,
                 PheanstalkInterface::DEFAULT_PRIORITY,
-                $delay / 1000,
+                (int) ($delay / 1000),
                 $this->ttr
             );
         } catch (Exception $exception) {