diff options
Diffstat (limited to 'vendor/fguillot/simple-queue/src/Queue.php')
-rw-r--r-- | vendor/fguillot/simple-queue/src/Queue.php | 92 |
1 files changed, 0 insertions, 92 deletions
diff --git a/vendor/fguillot/simple-queue/src/Queue.php b/vendor/fguillot/simple-queue/src/Queue.php deleted file mode 100644 index a88b55cb..00000000 --- a/vendor/fguillot/simple-queue/src/Queue.php +++ /dev/null @@ -1,92 +0,0 @@ -<?php - -namespace SimpleQueue; - -use DateTime; - -/** - * Class Queue - * - * @package SimpleQueue - */ -class Queue implements QueueAdapterInterface -{ - /** - * @var QueueAdapterInterface - */ - protected $queueAdapter; - - /** - * Queue constructor. - * - * @param QueueAdapterInterface $queueAdapter - */ - public function __construct(QueueAdapterInterface $queueAdapter) - { - $this->queueAdapter = $queueAdapter; - } - - /** - * Send a job - * - * @access public - * @param Job $job - * @return $this - */ - public function push(Job $job) - { - $this->queueAdapter->push($job); - return $this; - } - - /** - * Schedule a job in the future - * - * @access public - * @param Job $job - * @param DateTime $dateTime - * @return $this - */ - public function schedule(Job $job, DateTime $dateTime) - { - $this->queueAdapter->schedule($job, $dateTime); - return $this; - } - - /** - * Wait and get job from a queue - * - * @access public - * @return Job|null - */ - public function pull() - { - return $this->queueAdapter->pull(); - } - - /** - * Acknowledge a job - * - * @access public - * @param Job $job - * @return $this - */ - public function completed(Job $job) - { - $this->queueAdapter->completed($job); - return $this; - } - - /** - * Mark a job as failed - * - * @access public - * @param Job $job - * @return $this - */ - public function failed(Job $job) - { - $this->queueAdapter->failed($job); - return $this; - } -} |