Create ClientConfig from incoming options

nsqphp · Jun 9, 2021 · 28df682 · 28df682
1 parent 70c4667
commit 28df682
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/composer.json b/composer.json
@@ -13,7 +13,7 @@
     "require": {
         "php": "^8.0.1",
         "ext-json": "*",
-        "nsq/nsq": "^0.6.1",
+        "nsq/nsq": "^0.6.2",
         "symfony/framework-bundle": "^5.0",
         "symfony/messenger": "^5.0"
     },

diff --git a/src/Messenger/NsqTransportFactory.php b/src/Messenger/NsqTransportFactory.php
@@ -42,7 +42,7 @@ public function createTransport(string $dsn, array $options, SerializerInterface
         $topic = $nsqOptions['topic'] ?? 'symfony-messenger';
         $channel = $nsqOptions['channel'] ?? 'default';
 
-        $clientConfig = new ClientConfig();
+        $clientConfig = ClientConfig::fromArray($nsqOptions);
 
         return new NsqTransport(
             $address,