[amqp-bunny] bunny use DateTime as timestamp header, it should be converted to int.

Author: makasim

pkg/amqp-bunny/AmqpConsumer.php

@@ -204,6 +204,13 @@ private function convertMessage(Message $bunnyMessage)
         }
         unset($headers['application_headers']);
 
+        if (array_key_exists('timestamp', $headers)) {
+            /** @var \DateTime $date */
+            $date = $headers['timestamp'];
+
+            $headers['timestamp'] = (int) $date->format('U');
+        }
+
         $message = new AmqpMessage($bunnyMessage->content, $properties, $headers);
         $message->setDeliveryTag($bunnyMessage->deliveryTag);
         $message->setRedelivered($bunnyMessage->redelivered);

pkg/amqp-bunny/AmqpProducer.php

@@ -77,6 +77,10 @@ public function send(PsrDestination $destination, PsrMessage $message)
 
         $amqpProperties = $message->getHeaders();
 
+        if (array_key_exists('timestamp', $amqpProperties)) {
+            $amqpProperties['timestamp'] = \DateTime::createFromFormat('U', $amqpProperties['timestamp']);
+        }
+
         if ($appProperties = $message->getProperties()) {
             $amqpProperties['application_headers'] = $appProperties;
         }