Replaced constructor with owned method createMessage() in DbalContext.

rosamarsky · rosamarsky · commit 53ffb6e16741 · 2018-10-18T17:10:55.000+03:00
diff --git a/pkg/dbal/DbalContext.php b/pkg/dbal/DbalContext.php
@@ -133,7 +133,7 @@ public function createSubscriptionConsumer(): SubscriptionConsumer
      */
     public function convertMessage(array $dbalMessage): DbalMessage
     {
-        $dbalMessageObj = new DbalMessage(
+        $dbalMessageObj = $this->createMessage(
             $dbalMessage['body'],
             $dbalMessage['properties'] ? JSON::decode($dbalMessage['properties']) : [],
             $dbalMessage['headers'] ? JSON::decode($dbalMessage['headers']) : []

Original file line number	Diff line number	Diff line change
`@@ -133,7 +133,7 @@ public function createSubscriptionConsumer(): SubscriptionConsumer`
`133`	`133`	`*/`
`134`	`134`	`public function convertMessage(array $dbalMessage): DbalMessage`
`135`	`135`	`{`
`136`		`- $dbalMessageObj = new DbalMessage(`
	`136`	`+ $dbalMessageObj = $this->createMessage(`
`137`	`137`	`$dbalMessage['body'],`
`138`	`138`	`$dbalMessage['properties'] ? JSON::decode($dbalMessage['properties']) : [],`
`139`	`139`	`$dbalMessage['headers'] ? JSON::decode($dbalMessage['headers']) : []`