WP_Queue\Queue

Complexity

Total Complexity

5

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Test Coverage

Coverage

28.57%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	push()	0	2	1
A	worker()	0	2	1
A	cron()	0	5	2

<?php

namespace WP_Queue;

use WP_Queue\Connections\ConnectionInterface;

class Queue {

	/**
	 * @var ConnectionInterface
	 */
	protected $connection;

	/**
	 * @var string
	 */
	protected $identifier;

	/**
	 * Queue constructor.
	 *
	 * @param ConnectionInterface $connection
	 * @param string              $identifier
	 */
	public function __construct( ConnectionInterface $connection, $identifier ) {
		$this->connection = $connection;
		$this->identifier = $identifier;
	}

	/**
	 * Push a job onto the queue;
	 *
	 * @param Job $job
	 * @param int $delay
	 *
	 * @return bool|int
	 */
	public function push( Job $job, $delay = 0 ) {
		return $this->connection->push( $job, $delay );
	}

	/**
	 * Create a cron worker.
	 *
	 * @param int $attempts
	 */
	public function cron( $attempts = 3 ) {
		$cron = new Cron( $this->identifier, $this->worker( $attempts ) );

		if ( $cron->is_enabled() ) {
			$cron->init();
		}
	}

	/**
	 * Create a new worker.
	 *
	 * @param int $attempts
	 *
	 * @return Worker
	 */
	public function worker( $attempts ) {
		return new Worker( $this->connection, $attempts );
	}
}