diff --git a/composer.json b/composer.json index 9cf72d8..019a1da 100644 --- 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 index 1196ac0..00df361 100644 --- 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,