From 56753795af8dc40c722c0afc5019c3df792df430 Mon Sep 17 00:00:00 2001 From: Nicolas Grekas Date: Wed, 10 May 2023 13:53:45 +0200 Subject: [PATCH] [Messenger] Store dates in UTC when using Doctrine --- .../Messenger/Bridge/Doctrine/Transport/Connection.php | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/Connection.php b/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/Connection.php index 7e57b0fac98a7..9285c7efc0a03 100644 --- a/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/Connection.php +++ b/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/Connection.php @@ -125,7 +125,7 @@ public static function buildConfiguration(#[\SensitiveParameter] string $dsn, ar */ public function send(string $body, array $headers, int $delay = 0): string { - $now = new \DateTimeImmutable(); + $now = new \DateTimeImmutable('UTC'); $availableAt = $now->modify(sprintf('+%d seconds', $delay / 1000)); $queryBuilder = $this->driverConnection->createQueryBuilder() @@ -221,7 +221,7 @@ public function get(): ?array ->update($this->configuration['table_name']) ->set('delivered_at', '?') ->where('id = ?'); - $now = new \DateTimeImmutable(); + $now = new \DateTimeImmutable('UTC'); $this->executeStatement($queryBuilder->getSQL(), [ $now, $doctrineEnvelope['id'], @@ -342,7 +342,7 @@ public function getExtraSetupSqlForTable(Table $createdTable): array private function createAvailableMessagesQueryBuilder(): QueryBuilder { - $now = new \DateTimeImmutable(); + $now = new \DateTimeImmutable('UTC'); $redeliverLimit = $now->modify(sprintf('-%d seconds', $this->configuration['redeliver_timeout'])); return $this->createQueryBuilder()