PHP code example of fyre / queue

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

    

fyre / queue example snippets

use Fyre\Queue\QueueManager;

$queueManager = new QueueManager($container, $config);

$container->singleton(QueueManager::class);

$queueManager = $container->use(QueueManager::class);

$queue = $queueManager->build($options);

$queueManager->clear();

$config = $queueManager->getConfig($key);

$config = $queueManager->getConfig();

$hasConfig = $queueManager->hasConfig($key);

$isLoaded = $queueManager->isLoaded($key);

$queueManager->push($className, $arguments, $options);

$queueManager->setConfig($key, $options);

$queueManager->unload($key);

$queue = $queueManager->use($key);

$queue->clear($queueName);

$queue->complete($message);

$queue->fail($message);

$message = $queue->pop($queueName);

$queue->push($message);

$queues = $queue->queues();

$queue->reset($queueName);

$stats = $queue->stats($queueName);

$container->use(Config::class)->set('Queue.redis', $options);

use Fyre\Queue\Worker;

$worker = new Worker($container, $queueManager, $eventManager, $options);

$worker->run();

use Fyre\Queue\Message;

$message = new Message($options);

$after = $message->getTimestamp();

$config = $message->getConfig();

$hash = $message->getHash();

$queueName = $message->getQueue();

$isExpired = $message->isExpired();

$isReady = $message->isReady();

$isUnique = $message->isUnique();

$isValid = $message->isValid();

$shouldretry = $message->shouldRetry();

$commandRunner->run('queue:stats', ['--config', 'default', '--queue', 'default']);

$commandRunner->run('queue:worker', ['--config', 'default', '--queue', 'default', '--max-jobs', '99', '--max-runtime', '60']);