Rabbitmq publisher confirm test

confirm_test.php

<?php

$connection1 = new \AMQPConnection();
$connection1->connect();

$connection2 = new \AMQPConnection();
$connection2->connect();

$channel1 = new \AMQPChannel($connection1);

$channel2 = new \AMQPChannel($connection2);

$exchange = new \AMQPExchange($channel1);
$exchange->setName('test');
$exchange->setType('direct');
$exchange->declareExchange();

$queue = new \AMQPQueue($channel2);
$queue->setName('test');
$queue->declareQueue();
$queue->bind('test');

$channel1->confirmSelect();

$exchange->publish('foo');

$msg = $queue->get();

var_dump($msg->getBody());

$exchange->delete();
$queue->delete();