Bump nsq/nsq up to 0.6.1

nsqphp · Jun 9, 2021 · 5eea27c · 5eea27c
1 parent b3719b2
commit 5eea27c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/composer.json b/composer.json
@@ -13,7 +13,7 @@
     "require": {
         "php": "^8.0.1",
         "ext-json": "*",
-        "nsq/nsq": "^0.5.1",
+        "nsq/nsq": "^0.6.1",
         "symfony/framework-bundle": "^5.0",
         "symfony/messenger": "^5.0"
     },

diff --git a/src/Messenger/NsqSender.php b/src/Messenger/NsqSender.php
@@ -42,11 +42,7 @@ public function send(Envelope $envelope): Envelope
         $delayStamp = $envelope->last(DelayStamp::class);
         $delay = null !== $delayStamp ? $delayStamp->getDelay() : null;
 
-        if (null === $delay) {
-            $promise = $producer->publish($this->topic, $encodedMessage);
-        } else {
-            $promise = $producer->defer($this->topic, $encodedMessage, $delay);
-        }
+        $promise = $producer->publish($this->topic, $encodedMessage, $delay);
 
         wait($promise);