diff --git a/src/Queue/Redis.php b/src/Queue/Redis.php index c3a0143..e14c663 100644 --- a/src/Queue/Redis.php +++ b/src/Queue/Redis.php @@ -29,7 +29,10 @@ public function __construct(string $name, Client $redis) */ public function put($data, array $options = []): void { - $this->client->rpush($this->name, $this->serialize($data)); + $this->client->rpush( + $this->name, + $this->serialize($data) + ); } /** @@ -73,6 +76,9 @@ public function delete(Message $message): void */ public function release(Message $message, array $options = []): void { - $this->put($message->getSourceMessage()); + $this->client->rpush( + $this->name, + $message->getSourceMessage() + ); } } \ No newline at end of file