xyzshop/helper/queue/rdispatcher.php

<?php

namespace queue;

require_once(BASE_HELPER_PATH . '/queue/iqueue.php');


class DispatcherClient extends IClient
{
    private static $stInstance = null;

    public static function instance()
    {
        if (self::$stInstance == null) {
            self::$stInstance = new DispatcherClient();
        }

        return self::$stInstance;
    }

    public function __construct()
    {
        $db = new DispatcherDB();
        parent::__construct($db);
    }
}

class DispatcherDB extends IQueueDB
{
    public function __construct()
    {
        parent::__construct('QUEUE_DISPATCHER_CO');
    }
}

class DispatcherServer extends IServer
{
    public function __construct() {
        $queuedb = new DispatcherDB();
        parent::__construct($queuedb);
    }
}

class CoDispatcherDB extends IQueueDB
{
    public function __construct()
    {
        parent::__construct('QUEUE_DISPATCHER_CO');
    }
}

class CoDispatcherServer extends IServer
{
    public function __construct() {
        $queuedb = new CoDispatcherDB();
        parent::__construct($queuedb);
    }
}