Класс Phalcon\Queue\Beanstalk

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

<?php

use Phalcon\Queue\Beanstalk;

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

Константы

integer DEFAULT_DELAY

integer DEFAULT_PRIORITY

integer DEFAULT_TTR

string DEFAULT_TUBE

string DEFAULT_HOST

integer DEFAULT_PORT

Методы

public __construct ([array $parameters])

Конструктор

public connect ()

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

public put (mixed $data, [array $options])

Ставит задание в очередь, используя указанную трубку.

public reserve ([mixed $timeout])

Резервирует / блокирует готовую работу из указанной трубки.

public choose (mixed $tube)

Изменяет активную трубку. По умолчанию используется трубка "default".

public watch (mixed $tube)

Команда watch (смотреть) добавляет именованный канал в список наблюдения для текущего соединения.

public ignore (mixed $tube)

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

public pauseTube (mixed $tube, mixed $delay)

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

public kick (mixed $bound)

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

public stats ()

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

public statsTube (mixed $tube)

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

public listTubes ()

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

public listTubeUsed ()

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

public listTubesWatched ()

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

public peekReady ()

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

public peekBuried ()

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

public peekDelayed ()

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

public jobPeek (mixed $id)

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

final public readStatus ()

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

final public readYaml ()

Получение полезных данных YAML с сервера Beanstalkd

public read ([mixed $length])

Считывает пакет из сокета. Перед чтением из сокета проверяет наличие подключения.

public write (mixed $data)

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

public disconnect ()

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

public quit ()

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