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

Bump nsq/nsq up to 0.6.1

Browse Source
This commit is contained in:
Konstantin Grachev
2021-06-09 15:40:24 +03:00
parent b3719b2acf
commit 5eea27cb17
2 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/Messenger/NsqSender.php
View File

@ -42,11 +42,7 @@ final class NsqSender implements SenderInterface
$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);