Php AMQP

gistfile1.php

$connection = new AMQPConnection([
    'host'     => 'queue',
    'port'     => 5672,
    'login'    => 'guest',
    'password' => 'guest'
]);

$connection->connect();

$channel = new AMQPChannel($connection);

$queue = new AMQPQueue($channel);

$queue->setName('test-ampq-extension');
$queue->declareQueue();

$exchange = new AMQPExchange($channel);
$exchange->setName("exchange-hello-world");
$exchange->setType(AMQP_EX_TYPE_FANOUT);
$exchange->declareExchange();

$queue->bind($exchange->getName());

$exchange->publish('Hello you!');