| Server IP : 88.99.149.37 / Your IP : 216.73.216.141 Web Server : nginx/1.31.2 System : Linux server-88-99-149-37 6.12.0-124.56.5.el10_1.x86_64 #1 SMP PREEMPT_DYNAMIC Fri May 15 06:12:08 EDT 2026 x86_64 User : muralimurth ( 1015) PHP Version : 8.4.23 Disable Function : exec,system,passthru,shell_exec,proc_close,proc_open,dl,popen,show_source,posix_kill,posix_mkfifo,posix_getpwuid,posix_setpgid,posix_setsid,posix_setuid,posix_setgid,posix_seteuid,posix_setegid,posix_uname MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /home/muralimurth/public_html/wp-content/plugins/wp-migrate-db/class/Common/Queue/ |
Upload File : |
<?php
namespace DeliciousBrains\WPMDB\Common\Queue;
use DeliciousBrains\WPMDB\Common\Queue\Connections\ConnectionInterface;
class Queue {
/**
* @var ConnectionInterface
*/
protected $connection;
/**
* @var Cron
*/
protected $cron;
/**
* Queue constructor.
*
* @param ConnectionInterface $connection
*/
public function __construct( ConnectionInterface $connection ) {
$this->connection = $connection;
}
/**
* 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
* @param int $interval
*
* @return Cron
*/
public function cron( $attempts = 3, $interval = 5 ) {
if ( is_null( $this->cron ) ) {
$this->cron = new Cron( get_class( $this->connection ), $this->worker( $attempts ), $interval );
$this->cron->init();
}
return $this->cron;
}
/**
* Create a new worker.
*
* @param int $attempts
*
* @return Worker
*/
public function worker( $attempts ) {
return new Worker( $this->connection, $attempts );
}
}