Admin Control Panel v2.0

✎ Editing: BeanstalkdQueue.php ← Back

<?php namespace Illuminate\Queue;

use Pheanstalk_Job;

use Pheanstalk_Pheanstalk as Pheanstalk;

use Illuminate\Queue\Jobs\BeanstalkdJob;

class BeanstalkdQueue extends Queue implements QueueInterface {

/**

* The Pheanstalk instance.

* @var \Pheanstalk_Pheanstalk

protected $pheanstalk;

/**

* The name of the default tube.

* @var string

protected $default;

/**

* The "time to run" for all pushed jobs.

* @var int

protected $timeToRun;

/**

* Create a new Beanstalkd queue instance.

* @param  \Pheanstalk_Pheanstalk  $pheanstalk

* @param  string  $default

* @param  int  $timeToRun

* @return void

public function __construct(Pheanstalk $pheanstalk, $default, $timeToRun)

{

$this->default = $default;

$this->timeToRun = $timeToRun;

$this->pheanstalk = $pheanstalk;

}

/**

* Push a new job onto the queue.

* @param  string  $job

* @param  mixed   $data

* @param  string  $queue

* @return mixed

public function push($job, $data = '', $queue = null)

{

return $this->pushRaw($this->createPayload($job, $data), $queue);

}

/**

* Push a raw payload onto the queue.

* @param  string  $payload

* @param  string  $queue

* @param  array   $options

* @return mixed

public function pushRaw($payload, $queue = null, array $options = array())

{

return $this->pheanstalk->useTube($this->getQueue($queue))->put(

$payload, Pheanstalk::DEFAULT_PRIORITY, Pheanstalk::DEFAULT_DELAY, $this->timeToRun

);

}

/**

* Push a new job onto the queue after a delay.

* @param  \DateTime|int  $delay

* @param  string  $job

* @param  mixed   $data

* @param  string  $queue

* @return mixed

public function later($delay, $job, $data = '', $queue = null)

{

$payload = $this->createPayload($job, $data);

$pheanstalk = $this->pheanstalk->useTube($this->getQueue($queue));

return $pheanstalk->put($payload, Pheanstalk::DEFAULT_PRIORITY, $this->getSeconds($delay), $this->timeToRun);

}

/**

* Pop the next job off of the queue.

* @param  string  $queue

* @return \Illuminate\Queue\Jobs\Job|null

public function pop($queue = null)

{

$queue = $this->getQueue($queue);

$job = $this->pheanstalk->watchOnly($queue)->reserve(0);

if ($job instanceof Pheanstalk_Job)

{

return new BeanstalkdJob($this->container, $this->pheanstalk, $job, $queue);

}

/**

* Delete a message from the Beanstalk queue.

* @param  string  $queue

* @param  string  $id

* @return void

public function deleteMessage($queue, $id)

{

$this->pheanstalk->useTube($this->getQueue($queue))->delete($id);

}

/**

* Get the queue or return the default.

* @param  string|null  $queue

* @return string

public function getQueue($queue)

{

return $queue ?: $this->default;

}

/**

* Get the underlying Pheanstalk instance.

* @return \Pheanstalk_Pheanstalk

public function getPheanstalk()

{

return $this->pheanstalk;

}

Cancel