[Messenger] Store dates in UTC when using Dotrine

nicolas-grekas · nicolas-grekas · commit 959bc50bcc46 · 2023-05-10T13:53:45.000+02:00
diff --git a/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/Connection.php b/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/Connection.php
@@ -124,7 +124,7 @@ public static function buildConfiguration(string $dsn, array $options = []): arr
      */
     public function send(string $body, array $headers, int $delay = 0): string
     {
-        $now = new \DateTime();
+        $now = new \DateTime('UTC');
         $availableAt = (clone $now)->modify(sprintf('+%d seconds', $delay / 1000));
 
         $queryBuilder = $this->driverConnection->createQueryBuilder()
@@ -220,7 +220,7 @@ public function get(): ?array
                 ->update($this->configuration['table_name'])
                 ->set('delivered_at', '?')
                 ->where('id = ?');
-            $now = new \DateTime();
+            $now = new \DateTime('UTC');
             $this->executeStatement($queryBuilder->getSQL(), [
                 $now,
                 $doctrineEnvelope['id'],
@@ -344,7 +344,7 @@ public function getExtraSetupSqlForTable(Table $createdTable): array
 
     private function createAvailableMessagesQueryBuilder(): QueryBuilder
     {
-        $now = new \DateTime();
+        $now = new \DateTime('UTC');
         $redeliverLimit = (clone $now)->modify(sprintf('-%d seconds', $this->configuration['redeliver_timeout']));
 
         return $this->createQueryBuilder()
