diff --git a/MongodbContext.php b/MongodbContext.php
index <HASH>..<HASH> 100644
--- a/MongodbContext.php
+++ b/MongodbContext.php
@@ -114,7 +114,7 @@ class MongodbContext implements Context
      */
     public function convertMessage(array $mongodbMessage): MongodbMessage
     {
-        $mongodbMessageObj = new MongodbMessage(
+        $mongodbMessageObj = $this->createMessage(
             $mongodbMessage['body'],
             JSON::decode($mongodbMessage['properties']),
             JSON::decode($mongodbMessage['headers'])
Replaced constructor with owned method createMessage() in MongodbContext.