From ed2fdebce5763c005a73f7d021fbbfb230104e86 Mon Sep 17 00:00:00 2001
From: Konstantin Grachev <me@grachevko.ru>
Date: Thu, 8 Jul 2021 17:44:18 +0300
Subject: [PATCH] Set maxRdy to 1

---
 composer.json                         | 2 +-
 src/Messenger/NsqTransportFactory.php | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/composer.json b/composer.json
index 019a1da..2c520ed 100644
--- a/composer.json
+++ b/composer.json
@@ -13,7 +13,7 @@
     "require": {
         "php": "^8.0.1",
         "ext-json": "*",
-        "nsq/nsq": "^0.6.2",
+        "nsq/nsq": "0.7",
         "symfony/framework-bundle": "^5.0",
         "symfony/messenger": "^5.0"
     },
diff --git a/src/Messenger/NsqTransportFactory.php b/src/Messenger/NsqTransportFactory.php
index 244df9e..4f5a237 100644
--- a/src/Messenger/NsqTransportFactory.php
+++ b/src/Messenger/NsqTransportFactory.php
@@ -39,6 +39,7 @@ final class NsqTransportFactory implements TransportFactoryInterface
         }
 
         $nsqOptions = $query + $options;
+        $nsqOptions['rdyCount'] = 1;
 
         $address = sprintf('tcp://%s:%s', $components['host'], $components['port'] ?? $query['port'] ?? 4150);
         $topic = $nsqOptions['topic'] ?? 'symfony-messenger';