Класс Phalcon\Queue\Beanstalk

Исходный код на GitHub

Класс для доступа к службе очереди beanstalk. Частично реализует протокол версии 1.2

use Phalcon\Queue\Beanstalk;

$queue = new Beanstalk(
    [
        "host"       => "127.0.0.1",
        "port"       => 11300,
        "persistent" => true,
    ]
);

Константы

целое DEFAULT_DELAY

целое DEFAULT_PRIORITY

целое DEFAULT_TTR

строка DEFAULT_TUBE

строка DEFAULT_HOST

целое DEFAULT_PORT

Методы

public __construct ([массив $parameters])

public connect ()

Устанавливает соединение с сервером Beanstalkd

public put (смешанный $data, [массив $options])

Добавляет задание в очередь с использованием указанной трубы.

public reserve ([смешанный $timeout])

Зарезервировать/заблокировать готовое задание из указанной трубы.

public choose (смешанный $tube)

Изменить активную трубу. По умолчанию труба «default».

public watch (смешанный $tube)

Команда watch добавляет указанную трубу в список наблюдения для текущего соединения.

public ignore (смешанный $tube)

Удаляет указанную трубу из списка наблюдения для текущего соединения.

public pauseTube (смешанный $tube, смешанный $delay)

Может отложить резервирование нового задания на заданное время.

public kick (смешанный $bound)

Команда kick применяется только к текущей используемой трубе.

public stats ()

Предоставляет статистическую информацию о системе в целом.

public statsTube (смешанный $tube)

Предоставляет статистическую информацию об указанной трубе, если она существует.

public listTubes ()

Возвращает список всех существующих труб.

public listTubeUsed ()

Возвращает трубу, которая в данный момент используется клиентом.

public listTubesWatched ()

Возвращает список труб, которые в данный момент наблюдаются клиентом.

public peekReady ()

Просмотреть следующее готовое задание.

public peekBuried ()

Возвращает следующее задание в списке погребенных заданий.

public peekDelayed ()

Возвращает следующее задание в списке отложенных заданий.

public jobPeek (смешанный $id)

Команды peek позволяют клиенту просмотреть задание в системе.

final public readStatus ()

Считывает последний статус с сервера Beanstalkd

final public readYaml ()

Извлечь YAML-загрузку с сервера Beanstalkd

public read ([смешанный $length])

Читает пакет из сокета. Перед чтением из сокета проверяет доступность соединения.

protected write (смешанный $data)

Записывает данные в сокет. Выполняет подключение, если оно недоступно.

public disconnect ()

Закрывает соединение с сервером beanstalk.

public quit ()

Просто закрывает соединение.