Fix AMQP message timestamp error

sonata-project · Mar 13, 2019 · 319e723 · 319e723
1 parent 621b79b
commit 319e723
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Backend/AMQPBackend.php b/src/Backend/AMQPBackend.php
@@ -167,7 +167,7 @@ public function publish(MessageInterface $message)
 
         $amqpMessage = $this->getContext()->createMessage($body);
         $amqpMessage->setContentType('text/plain'); // application/json ?
-        $amqpMessage->setTimestamp($message->getCreatedAt()->format('U'));
+        $amqpMessage->setTimestamp($message->getCreatedAt()->getTimestamp());
         $amqpMessage->setDeliveryMode(AmqpMessage::DELIVERY_MODE_PERSISTENT);
         $amqpMessage->setRoutingKey($this->key);