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

Revert json_encode

Browse Source
This commit is contained in:
Konstantin Grachev
2021-02-15 22:44:22 +03:00
parent e824d643c9
commit bd10eb8742
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/Messenger/NsqTransport.php
View File

@@ -48,15 +48,16 @@ final class NsqTransport implements TransportInterface
public function send(Envelope $envelope): Envelope public function send(Envelope $envelope): Envelope
{ {
$encodedMessage = $this->serializer->encode($envelope->withoutAll(NsqReceivedStamp::class)); $encodedMessage = $this->serializer->encode($envelope->withoutAll(NsqReceivedStamp::class));
$encodedMessage = json_encode($encodedMessage, JSON_THROW_ON_ERROR | JSON_UNESCAPED_UNICODE);
/** @var DelayStamp|null $delayStamp */ /** @var DelayStamp|null $delayStamp */
$delayStamp = $envelope->last(DelayStamp::class); $delayStamp = $envelope->last(DelayStamp::class);
$delay = null !== $delayStamp ? $delayStamp->getDelay() : null; $delay = null !== $delayStamp ? $delayStamp->getDelay() : null;
if (null === $delay) { if (null === $delay) {
$this->producer->pub($this->topic, $encodedMessage['body']); $this->producer->pub($this->topic, $encodedMessage);
} else { } else {
$this->producer->dpub($this->topic, $encodedMessage['body'], $delay); $this->producer->dpub($this->topic, $encodedMessage, $delay);
} }
return $envelope; return $envelope;