File: vendor/jackbooted/queue/Queue.php

Recommend this page to a friend!
  Classes of Brett Dutton  >  JackBooted PHP Framework  >  vendor/jackbooted/queue/Queue.php  >  Download  
File: vendor/jackbooted/queue/Queue.php
Role: Class source
Content type: text/plain
Description: Class source
Class: JackBooted PHP Framework
Web application framework using simplified MVC
Author: By
Last change:
Date: 4 years ago
Size: 2,543 bytes
 

 

Contents

Class file image Download
<?php
namespace Jackbooted\Queue;
/**
 * @copyright Confidential and copyright (c) 2016 Jackbooted Software. All rights reserved.
 *
 * Written by Brett Dutton of Jackbooted Software
 * brett at brettdutton dot com
 *
 * This software is written and distributed under the GNU General Public
 * License which means that its source code is freely-distributed and
 * available to the general public.
 */

class Queue extends \Jackbooted\Util\JB {
    const
DEF_PRIORITY = 10;
    const
DEF_TIME_TO_RUN = 21600; // 6 hrs

   
private static $resources = [];
    private static
$log = null;

    public static function
init () {
       
self::$log = \Jackbooted\Util\Log4PHP::logFactory ( __CLASS__ );
    }

    public static function
enQueue ( $queueName, $payLoad, $pri=self::DEF_PRIORITY, $delay=0, $ttr=self::DEF_TIME_TO_RUN ) {
        if ( ! isset (
self::$resources[$queueName] ) ) {
           
self::$resources[$queueName] = [ 'in', 'out' ];
        }

        if ( ! isset (
self::$resources[$queueName]['in'] ) ) {
           
self::$resources[$queueName]['in'] = new \Beanstalk\Client();
           
self::$resources[$queueName]['in']->connect();
           
self::$resources[$queueName]['in']->useTube( $queueName );
        }
        return
self::$resources[$queueName]['in']->put( $pri, $delay, $ttr, $payLoad );
    }

    public static function
deQueue ( $queueName ) {
        if ( ! isset (
self::$resources[$queueName] ) ) {
           
self::$resources[$queueName] = [ 'in', 'out' ];
        }

        if ( ! isset (
self::$resources[$queueName]['out'] ) ) {
           
self::$resources[$queueName]['out'] = new \Beanstalk\Client();
           
self::$resources[$queueName]['out']->connect();
           
self::$resources[$queueName]['out']->watch( $queueName );
        }

        if ( (
$job = self::$resources[$queueName]['out']->reserve( 0 ) ) === false ) return false;

       
self::$resources[$queueName]['out']->delete( $job['id'] );
        return
$job['body'];
    }

    public static function
disconnect ( $queueName ) {
        if ( isset (
self::$resources[$queueName]['in'] ) ) {
           
self::$resources[$queueName]['in']->disconnect();
        }
        if ( isset (
self::$resources[$queueName]['out'] ) ) {
           
self::$resources[$queueName]['out']->disconnect();
        }
        unset(
self::$resources[$queueName] );
    }

    public function
__destruct()
    {
        foreach (
array_keys( self::$resources ) as $queueName ) {
           
self::disconnect( $queueName );
        }
    }
}


For more information send a message to info at phpclasses dot org.