home
/
zktecojo
/
public_html
/
vendor
/
laravel
/
framework
/
src
/
Illuminate
/
Queue
➕ New
📤 Upload
✎ 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; } }
💾 Save Changes
Cancel
📤 Upload File
×
Select File
Upload
Cancel
➕ Create New
×
Type
📄 File
📁 Folder
Name
Create
Cancel
✎ Rename Item
×
Current Name
New Name
Rename
Cancel
🔐 Change Permissions
×
Target File
Permission (e.g., 0755, 0644)
0755
0644
0777
Apply
Cancel