// Конфигурационные параметры
// @see Zend_Queue_Adapater::__construct()
'name' => 'queue1',
);
// Создание очереди на основе массива
$queue = new Zend_Queue('Array', $options);
// Получение списка очередей
foreach ($queue->getQueues() as $name) {
}
// Создание новой очереди
$queue2 = $queue->createQueue('queue2');
// Подсчёт количества сообщений в очереди (реализует интерфейс Countable из SPL)
// Получение 5 сообщений из очереди
$messages = $queue->receive(5);
foreach ($messages as $i => $message) {
echo $message->
body,
"\n";
// Сообщение обработано, его можно удалить
$queue->deleteMessage($message);
}
// Отправка сообщения в текущую очередь
$queue->send('My Test Message');
// Удаление созданной очереди и всех сообщений в ней
$queue->deleteQueue('queue2');