Fixed issue with AMQPTable/array in headers

event-band · Aug 30, 2017 · 2a38cf4 · 2a38cf4
1 parent 8e93093
commit 2a38cf4
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/EventBand/Transport/AmqpLib/AmqpMessageUtils.php b/src/EventBand/Transport/AmqpLib/AmqpMessageUtils.php
@@ -13,6 +13,7 @@
 use EventBand\Transport\Amqp\Driver\CustomAmqpMessage;
 use EventBand\Transport\Amqp\Driver\MessageDelivery;
 use PhpAmqpLib\Message\AMQPMessage as AmqpLibMessage;
+use PhpAmqpLib\Wire\AMQPTable;
 
 /**
  * Utils for AMQPMessage driver adoption
@@ -52,7 +53,12 @@ public static function createMessage(AmqpLibMessage $message)
             }
         }
         if ($message->has('application_headers')) {
-            $properties['headers'] = $message->get('application_headers');
+            $headers = $message->get('application_headers');
+            if ($headers instanceof AMQPTable) {
+                $properties['headers'] = $headers->getNativeData();
+            } elseif (is_array($headers)) {
+                $properties['headers'] = $headers;
+            }
         }
 
         return CustomAmqpMessage::fromProperties($properties);