for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Zenstruck\Queue\Driver;
/**
* @author Kevin Bond <[email protected]>
*/
final class RedisDriver extends BaseRedisDriver
{
private $client;
* @param \Redis $client
* @param string $queueName
public function __construct(\Redis $client, $queueName)
$this->client = $client;
parent::__construct($queueName);
}
* {@inheritdoc}
protected function rPush($queueName, $payload)
$this->client->rPush($queueName, $payload);
protected function lPop($queueName)
$data = $this->client->lPop($queueName);
return false === $data ? null : $data;
kbond /
php-queue
