PHP Rabbit MQ Чтение определенного сообщения из одной очереди

Question

Мне нужна помощь, чтобы использовать определенное значение в моей очереди, я следую примеру с сайта rabbitMQ: http://www.rabbitmq.com/tutorials/tutorial-five-php.html

в основном у меня будет обмен (тема) с некоторыми ключами маршрутизации, каждый ключ маршрутизации указывает на очередь.

Обмен: SAC

Очередь = сак-ями

И необходимо прочитать конкретное значение, например:

У очереди сак-ями есть 3 записи,

• "101"
• "103"

Я был вставлен таким образом ..

• php emit_log_topic.php "protocol.101" "101"
• php emit_log_topic.php "protocol.102" "102"
• php emit_log_topic.php "protocol.103" "103"

Мне нужно удалить 103 из очереди, как мне это сделать?

вот мой код: выбрасывать ..

<?php

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

$exchange = "sac";
$queue = "sac-yami";
$type = 'topic';
$message = implode(' ', array_slice($argv, 2));

$connection = new AMQPStreamConnection('MYHOST', PORT, 'USER', 'PASS','/');
$channel = $connection->channel();
$routing_key = isset($argv[1]) && !empty($argv[1]) ? $argv[1] : 'anonymous.info';
$channel->queue_declare($queue, false, true, false, false);
$channel->exchange_declare($exchange, $type, false, true, false);
$channel->queue_bind($queue, $exchange, $routing_key);

$msg = new AMQPMessage($message);
$return = $channel->basic_publish($msg, $exchange, $routing_key);
$channel->close();
$connection->close();

и читать:

$rabbit->connection = new AMQPStreamConnection($rabbit->host, $rabbit->port, $rabbit->user, $rabbit->pass, $rabbit->vhost);
$rabbit->channel = $rabbit->connection->channel();

$rabbit->channel->queue_declare($queue, false, true, false, false);
$rabbit->channel->exchange_declare($queue, 'topic', false, true, false);
$rabbit->channel->queue_bind($queue, $routingKey);
$rabbit->channel->basic_consume($queue, $consumerTag, false, false, false, false, array($rabbit, 'processMessage'));

    function processMessage($message)
        {
            $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);
    print_r($message);
        }

Answer 1

Поскольку все три сообщения направляются в одну и ту же очередь (sac-yami), вы должны использовать эту очередь для чтения сообщений. Они будут доставлены в том порядке, в котором они были опубликованы - 101, 102 и 103. Невозможно прочитать сообщение 103 перед двумя другими.

---

_{ПРИМЕЧАНИЕ: команда RabbitMQ отслеживает список рассылки rabbitmq-users и только иногда отвечает на вопросы в StackOverflow.}