Create ClientConfig from incoming options
This commit is contained in:
@ -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"
|
||||
},
|
||||
|
@ -42,7 +42,7 @@ final class NsqTransportFactory implements TransportFactoryInterface
|
||||
$topic = $nsqOptions['topic'] ?? 'symfony-messenger';
|
||||
$channel = $nsqOptions['channel'] ?? 'default';
|
||||
|
||||
$clientConfig = new ClientConfig();
|
||||
$clientConfig = ClientConfig::fromArray($nsqOptions);
|
||||
|
||||
return new NsqTransport(
|
||||
$address,
|
||||
|
Reference in New Issue
Block a user