nsq/nsq-bundle
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge options from dsn with passed options

Browse Source
This commit is contained in:
Konstantin Grachev
2021-06-09 18:49:47 +03:00
parent 28df682351
commit 2b9e41a857
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/Messenger/NsqTransportFactory.php
View File

@ -29,16 +29,18 @@ final class NsqTransportFactory implements TransportFactoryInterface
*/ */
public function createTransport(string $dsn, array $options, SerializerInterface $serializer): TransportInterface public function createTransport(string $dsn, array $options, SerializerInterface $serializer): TransportInterface
{ {
if (false === $parsedUrl = parse_url($dsn)) { if (false === $components = parse_url($dsn)) {
throw new InvalidArgumentException(sprintf('The given Nsq DSN "%s" is invalid.', $dsn)); throw new InvalidArgumentException(sprintf('The given Nsq DSN "%s" is invalid.', $dsn));
} }
$nsqOptions = []; $query = [];
if (isset($parsedUrl['query'])) { if (isset($components['query'])) {
parse_str($parsedUrl['query'], $nsqOptions); parse_str($components['query'], $query);
} }
$address = sprintf('tcp://%s:%s', $parsedUrl['host'] ?? 'nsqd', $parsedUrl['port'] ?? 4150); $nsqOptions = $query + $options;
$address = sprintf('tcp://%s:%s', $components['host'], $components['port'] ?? $query['port'] ?? 4150);
$topic = $nsqOptions['topic'] ?? 'symfony-messenger'; $topic = $nsqOptions['topic'] ?? 'symfony-messenger';
$channel = $nsqOptions['channel'] ?? 'default'; $channel = $nsqOptions['channel'] ?? 'default';