A demo of how to use amqphp

gistfile1.php

<?php

require 'amqp.php';

use amqp_091 as amqp;
use amqp_091\protocol;
use amqp_091\wire;

$params = array('username' => 'testing',
                'userpass' => 'letmein',
                'vhost' => 'robin',
                'exchange' => 'unit-test-basic',
                'socketImpl' => '\amqp_091\Socket',
                'socketParams' => array(
                                        'host' => 'localhost',
                                        'port' => '5672'));

$c = new amqp\Connection($params);
$c->connect();
$chan = $c->getChannel();
$msg = $chan->basic('publish', array('content-type' => 'text/plain',
                                     'content-encoding' => 'UTF-8',
                                     'routing-key' => '',
                                     'mandatory' => false,
                                     'immediate' => false,
                                     'exchange' => 'unit-test-basic'), 'This is the message content');
$chan->invoke($msg);
echo "Done!\n";