Skip to content

Commit

Permalink
Fixing bug where Redis messages being released were pushing only the …
Browse files Browse the repository at this point in the history
…message payload instead of the source message.
  • Loading branch information
brentscheffler committed Mar 30, 2020
1 parent b431a0e commit cac91ce
Showing 1 changed file with 8 additions and 2 deletions.
10 changes: 8 additions & 2 deletions src/Queue/Redis.php
Original file line number Diff line number Diff line change
Expand Up @@ -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)
);
}

/**
Expand Down Expand Up @@ -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()
);
}
}

0 comments on commit cac91ce

Please sign in to comment.