Fix headers handling

event-band · May 25, 2017 · f508bf1 · f508bf1
1 parent 659961a
commit f508bf1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/EventBand/Transport/AmqpLib/AmqpMessageUtils.php b/src/EventBand/Transport/AmqpLib/AmqpMessageUtils.php
@@ -26,7 +26,6 @@ final class AmqpMessageUtils
     const DELIVERY_MODE_PERSISTENT = 2;
 
     private static $PROPERTY_MAP = [
-        'headers' => 'application_headers',
         'contentType' => 'content_type',
         'contentEncoding' => 'content_encoding',
         'messageId' => 'message_id',
@@ -52,6 +51,9 @@ public static function createMessage(AmqpLibMessage $message)
                 $properties[$name] = $message->get($amqpLibName);
             }
         }
+        if ($message->has('application_headers')) {
+            $properties['headers'] = $message->get('application_headers')->getNativeData();
+        }
 
         return CustomAmqpMessage::fromProperties($properties);
     }