Add body, properties and headers to client's message constructor.

makasim · makasim · commit 7dbc9fde5166 · 2017-05-25T12:54:34.000+03:00
fixes php-enqueue#88
diff --git a/pkg/enqueue/Client/Message.php b/pkg/enqueue/Client/Message.php
@@ -78,10 +78,12 @@ class Message
      */
     private $properties = [];
 
-    public function __construct()
+    public function __construct($body = '', array $properties = [], array $headers = [])
     {
-        $this->headers = [];
-        $this->properties = [];
+        $this->body = $body;
+        $this->headers = $headers;
+        $this->properties = $properties;
+
         $this->scope = static::SCOPE_MESSAGE_BUS;
     }
 
diff --git a/pkg/enqueue/Tests/Client/MessageTest.php b/pkg/enqueue/Tests/Client/MessageTest.php
@@ -7,9 +7,22 @@
 
 class MessageTest extends TestCase
 {
-    public function testCouldBeConstructedWithoutAnyArguments()
+    public function testCouldBeConstructedWithoutArguments()
     {
-        new Message();
+        $message = new Message();
+
+        $this->assertSame('', $message->getBody());
+        $this->assertSame([], $message->getProperties());
+        $this->assertSame([], $message->getHeaders());
+    }
+
+    public function testCouldBeConstructedWithOptionalArguments()
+    {
+        $message = new Message('theBody', ['barProp' => 'barPropVal'], ['fooHeader' => 'fooHeaderVal']);
+
+        $this->assertSame('theBody', $message->getBody());
+        $this->assertSame(['barProp' => 'barPropVal'], $message->getProperties());
+        $this->assertSame(['fooHeader' => 'fooHeaderVal'], $message->getHeaders());
     }
 
     public function testShouldAllowGetPreviouslySetBody()

Original file line number	Diff line number	Diff line change
`@@ -78,10 +78,12 @@ class Message`
`78`	`78`	`*/`
`79`	`79`	`private $properties = [];`
`80`	`80`
`81`		`- public function __construct()`
	`81`	`+ public function __construct($body = '', array $properties = [], array $headers = [])`
`82`	`82`	`{`
`83`		`- $this->headers = [];`
`84`		`- $this->properties = [];`
	`83`	`+ $this->body = $body;`
	`84`	`+ $this->headers = $headers;`
	`85`	`+ $this->properties = $properties;`
	`86`	`+`
`85`	`87`	`$this->scope = static::SCOPE_MESSAGE_BUS;`
`86`	`88`	`}`
`87`	`89`