diff --git a/composer.json b/composer.json index ddcf76b..9cf72d8 100644 --- 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 index 6ff28f1..751e482 100644 --- 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);