[Queue] Message try add createdAt field #1271

Author: asika32764

packages/queue/src/Driver/DatabaseQueueDriver.php

@@ -53,7 +53,7 @@ public function __construct(
      */
     public function push(QueueMessage $message): string
     {
-        $time = new DateTimeImmutable('now');
+        $time = $message->createdAt ?? new DateTimeImmutable('now');
 
         $data = [
             'channel' => $message->getChannel() ?: $this->channel,
@@ -143,7 +143,7 @@ function () use ($now, $query) {
         $message->setBody(json_decode($data['body'], true, 512, JSON_THROW_ON_ERROR));
         $message->setRawBody($data['body']);
         $message->setChannel($channel);
-        $message->setCreatedAt($data['createdAt']);
+        $message->setCreatedAt($data['created']);
 
         return $message;
     }

packages/queue/src/Driver/InfinityQueueDriver.php

@@ -26,7 +26,8 @@ public function push(QueueMessage $message): string
     public function pop(?string $channel = null): ?QueueMessage
     {
         return new QueueMessage($this->job)
-            ->setId(uid('mq__'));
+            ->setId(uid('mq__'))
+            ->setCreatedAt('now');
     }
 
     public function delete(QueueMessage $message): static

packages/queue/src/Driver/PdoQueueDriver.php

@@ -49,7 +49,7 @@ public function __construct(
      */
     public function push(QueueMessage $message): string
     {
-        $time = new DateTimeImmutable('now');
+        $time = $message->createdAt ?? new DateTimeImmutable('now');
 
         $data = [
             ':channel' => $message->getChannel() ?: $this->channel,