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