Replaced constructor with owned method createMessage() in MongodbContext.

rosamarsky · rosamarsky · commit 410b500c0622 · 2018-10-18T17:12:04.000+03:00
diff --git a/pkg/mongodb/MongodbContext.php b/pkg/mongodb/MongodbContext.php
@@ -114,7 +114,7 @@ public function createSubscriptionConsumer(): SubscriptionConsumer
      */
     public function convertMessage(array $mongodbMessage): MongodbMessage
     {
-        $mongodbMessageObj = new MongodbMessage(
+        $mongodbMessageObj = $this->createMessage(
             $mongodbMessage['body'],
             JSON::decode($mongodbMessage['properties']),
             JSON::decode($mongodbMessage['headers'])

Original file line number	Diff line number	Diff line change
`@@ -114,7 +114,7 @@ public function createSubscriptionConsumer(): SubscriptionConsumer`
`114`	`114`	`*/`
`115`	`115`	`public function convertMessage(array $mongodbMessage): MongodbMessage`
`116`	`116`	`{`
`117`		`- $mongodbMessageObj = new MongodbMessage(`
	`117`	`+ $mongodbMessageObj = $this->createMessage(`
`118`	`118`	`$mongodbMessage['body'],`
`119`	`119`	`JSON::decode($mongodbMessage['properties']),`
`120`	`120`	`JSON::decode($mongodbMessage['headers'])`