fix type

Author: nepster-web

src/Transport/DoctrineDbalTransport.php

@@ -56,7 +56,7 @@ public function fetchMessage(array $queues = []): ?Message
             ->andWhere('exact_time <= :nowTime')
             ->addOrderBy('priority', 'asc')
             ->addOrderBy('created_at', 'asc')
-            ->setParameter('redeliveredAt', (new DateTimeImmutable('now'))->format('Y-m-d H:i:s'), Types::DATETIME_IMMUTABLE)
+            ->setParameter('redeliveredAt', (new DateTimeImmutable('now'))->format('Y-m-d H:i:s'), Types::STRING)
             ->setParameter('statuses', [Status::NEW, Status::REDELIVERED], Connection::PARAM_STR_ARRAY)
             ->setParameter('nowTime', $nowTime, Types::INTEGER)
             ->setMaxResults(1);
@@ -108,8 +108,8 @@ public function send(Message $message): void
             $rowsAffected = $this->connection->insert(DoctrineDbalTableCreator::getTableName(), $dataMessage, [
                 'id' => Types::GUID,
                 'status' => Types::STRING,
-                'created_at' => Types::DATETIME_IMMUTABLE,
-                'redelivered_at' => Types::DATETIME_IMMUTABLE,
+                'created_at' => Types::STRING,
+                'redelivered_at' => Types::STRING,
                 'attempts' => Types::SMALLINT,
                 'queue' => Types::STRING,
                 'event' => Types::STRING,

tests/Transport/DoctrineDbalTransportTest.php

@@ -59,8 +59,8 @@ public function testSend(): void
 
         self::assertEquals(Types::GUID, $connection::$data['insert']['types']['id']);
         self::assertEquals(Types::STRING, $connection::$data['insert']['types']['status']);
-        self::assertEquals(Types::DATETIME_IMMUTABLE, $connection::$data['insert']['types']['created_at']);
-        self::assertEquals(Types::DATETIME_IMMUTABLE, $connection::$data['insert']['types']['redelivered_at']);
+        self::assertEquals(Types::STRING, $connection::$data['insert']['types']['created_at']);
+        self::assertEquals(Types::STRING, $connection::$data['insert']['types']['redelivered_at']);
         self::assertEquals(Types::SMALLINT, $connection::$data['insert']['types']['attempts']);
         self::assertEquals(Types::STRING, $connection::$data['insert']['types']['queue']);
         self::assertEquals(Types::STRING, $connection::$data['insert']['types']['event']);