Use a property attributes instead of a key in headers

Author: p-pichet

docs/transport/gps.md

@@ -62,21 +62,6 @@ $context->declareTopic($fooTopic);
 $context->createProducer()->send($fooTopic, $message);
 ```
 
-You can send attributes using headers :
-
-```php
-<?php
-/** @var \Enqueue\Gps\GpsContext $context */
-
-$fooTopic = $context->createTopic('foo');
-$attributes = ['key1' => 'value1'];
-$message = $context->createMessage('Hello world!', [], ['attributes' => $attributes]);
-
-$context->declareTopic($fooTopic);
-
-$context->createProducer()->send($fooTopic, $message);
-```
-
 ## Consume message:
 
 Before you can consume message you have to subscribe a queue to the topic.

pkg/gps/GpsMessage.php

@@ -24,6 +24,11 @@ class GpsMessage implements Message, \JsonSerializable
      */
     private $headers;
 
+    /**
+     * @var array
+     */
+    private $attributes;
+
     /**
      * @var bool
      */
@@ -34,18 +39,12 @@ class GpsMessage implements Message, \JsonSerializable
      */
     private $nativeMessage;
 
-    /**
-     * @var array
-     */
-    private $attributes;
-
-    public function __construct(string $body = '', array $properties = [], array $headers = [])
+    public function __construct(string $body = '', array $properties = [], array $headers = [], array $attributes = [])
     {
         $this->body = $body;
         $this->properties = $properties;
-        $this->attributes = $headers['attributes'] ?? [];
-        unset($headers['attributes']);
         $this->headers = $headers;
+        $this->attributes = $attributes;
 
         $this->redelivered = false;
     }
@@ -181,6 +180,11 @@ public function setNativeMessage(?GoogleMessage $message = null): void
         $this->nativeMessage = $message;
     }
 
+    public function setAttributes(array $attributes): void
+    {
+        $this->attributes = $attributes;
+    }
+
     public function getAttributes(): array
     {
         return $this->attributes;

pkg/gps/Tests/GpsMessageTest.php

@@ -73,7 +73,7 @@ public function testThrowIfMalformedJsonGivenOnUnsterilizedFromJson()
 
     public function testGetAttributes()
     {
-        $message = new GpsMessage('the body', [], ['attributes' => ['key1' => 'value1']]);
+        $message = new GpsMessage('the body', [], [], ['key1' => 'value1']);
 
         $attributes = $message->getAttributes();
 

pkg/gps/Tests/GpsProducerTest.php

@@ -35,8 +35,7 @@ public function testShouldSendMessage()
             ->method('publish')
             ->with($this->identicalTo([
                 'data' => '{"body":"","properties":[],"headers":[]}',
-            ])
-            );
+            ]));
 
         $client = $this->createPubSubClientMock();
         $client
@@ -60,7 +59,7 @@ public function testShouldSendMessage()
     public function testShouldSendMessageWithAttributes()
     {
         $topic = new GpsTopic('topic-name');
-        $message = new GpsMessage('', [], ['attributes' => ['key1' => 'value1']]);
+        $message = new GpsMessage('', [], [], ['key1' => 'value1']);
 
         $gtopic = $this->createGTopicMock();
         $gtopic