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

Set maxRdy to 1

Browse Source
This commit is contained in:
Konstantin Grachev
2021-07-08 17:44:18 +03:00
parent 819f2c9e5d
commit ed2fdebce5
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
composer.json
View File

@ -13,7 +13,7 @@
"require": { "require": {
"php": "^8.0.1", "php": "^8.0.1",
"ext-json": "*", "ext-json": "*",
"nsq/nsq": "^0.6.2", "nsq/nsq": "0.7",
"symfony/framework-bundle": "^5.0", "symfony/framework-bundle": "^5.0",
"symfony/messenger": "^5.0" "symfony/messenger": "^5.0"
}, },

1
src/Messenger/NsqTransportFactory.php
View File

@ -39,6 +39,7 @@ final class NsqTransportFactory implements TransportFactoryInterface
} }
$nsqOptions = $query + $options; $nsqOptions = $query + $options;
$nsqOptions['rdyCount'] = 1;
$address = sprintf('tcp://%s:%s', $components['host'], $components['port'] ?? $query['port'] ?? 4150); $address = sprintf('tcp://%s:%s', $components['host'], $components['port'] ?? $query['port'] ?? 4150);
$topic = $nsqOptions['topic'] ?? 'symfony-messenger'; $topic = $nsqOptions['topic'] ?? 'symfony-messenger';