PHP Redis Queue
Starting with composer
composer require leocarmo/php-redis-queue
For examples, see
examples
folder on this project
The Publisher
use LeoCarmo\RedisQueue\Publisher;
$redis = new Redis();
$redis->connect('localhost');
Publisher::setQueueClient('my-queue', $redis);
Publisher::pushMessage('my-queue', [
'message' => 'Hello World!'
]);
The Listener
use LeoCarmo\RedisQueue\Listener;
$redis = new Redis();
$redis->connect('localhost');
Listener::setQueueClient('my-queue', $redis);
Listener::restoreMessagesFromProcessingQueue('my-queue', 1);
while (true) {
Listener::processMessages('my-queue', 1, 1, function ($events) {
dump($events);
});
}
Tests soon