5

Как из php скрипта определить количество сообщений в очереди? Вот мой код:

<?php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

$connection = new AMQPStreamConnection('localhost', 5672, 'user', 'pass');
$channel = $connection->channel();
$channel->basic_consume('sms_inbox', '', true, false, false, false, $callback);

2 ответа 2

2

Это костыль для решения этого вопроса. Как сделать вывод количества сообщений в очереди средствами php без функции exec() у меня так и не вышло

$content = exec('rabbitmqctl list_queues|grep sms_inbox');
preg_match_all('/sms_inbox(.+)/', $content, $result, PREG_PATTERN_ORDER);
$cnt = trim($result[1][0]);
1
  • Это костыль для решения этого вопроса. Как сделать вывод количества сообщений в очереди средствами php без функции exec() у меня так и не вышло
    – vadim
    5 июн 2016 в 8:04
0
$queue = new AMQPQueue($channel);
$queue->setName('sms_inbox');
$queue->setFlags(AMQP_DURABLE);
echo $queue->declare() . PHP_EOL; // до 1.2.0

или с версии rabbitmq 1.2.0:

echo $queue->declareQueue() . PHP_EOL; // с 1.2.0

Метод declare() кроме того, что объявляет очередь, возвращает количество сообщений в очереди.

Return Values

Returns the message count.

С версии amqp 1.2.0 AMQPQueue::declare() deprecated и нужно использовать AMQPQueue::declareQueue().

2
  • Это объявит очередь, но ответ совершенно точно не будет ничего содержать количество сообщений
    – etki
    5 июн 2016 в 10:39
  • @Etki у меня работает вариант с ->declareQueue() - возвращает кол-во сообщений. с declare тоже работает, но с ошибкой, т.к. declare deprecated с 1.2.0.
    – jekaby
    5 июн 2016 в 10:58

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.