Я пытаюсь доставить сообщение в обмен, а затем в определенную очередь.
$conn = new AMQPConnection(RABBITMQ_NODE_IP_ADDRESS, RABBITMQ_PORT, RABBITMQ_USERNAME, RABBITMQ_PASSWORD, RABBITMQ_VHOST);
$queue = RABBITMQ_QUEUE_CSV;
$exchange = RABBITMQ_EXCHANGE;
$ch = $conn->channel();
$ch->exchange_declare($exchange, 'direct', false, true, false);
$ch->queue_declare($queue, false, true, false, false);
$ch->queue_bind($queue, $exchange, $queue);
$msg = new AMQPMessage(json_encode($params), array('content_type' => 'text/plain', 'delivery_mode' => 2));
$ch->basic_publish($msg, $exchange);
$ch->close();
$conn->close();
$status = Array("status" => "Job queued");
тип обмена — «прямой», затем я добавил очередь с именем «foo_bar» и в качестве «ключа маршрутизации» использовал ту же строку «foo_bar».
Просто читаю документацию http://www.rabbitmq.com/tutorials/tutorial-four-php.html Я не могу понять, где я делаю неправильно 🙁
Вот: $ch->queue_bind($queue, $exchange, $queue);
Вы связываете очередь, используя $queue
ключ маршрутизации.
Вот: $ch->basic_publish($msg, $exchange);
Вы публикуете сообщение с пустым ключом маршрутизации. Чтобы сообщение достигло очереди, ключ маршрутизации в привязке и публикации сообщения должен совпадать
Других решений пока нет …