Submitting an Order to an AMQP Exchange with PHP

gistfile1.aw

$cnn = new AMQPConnection();
$cnn->connect();

// Create a channel
$ch = new AMQPChannel($cnn);

// Declare the orders-exchange
$ex = new AMQPExchange($ch);
$ex->setName("orders-exchange");
$ex->setType(AMQP_EX_TYPE_DIRECT);
$ex->setFlags(AMQP_DURABLE);
$ex->declare();

// Publish a message to the exchange with the "order.submit" routing key
$msg = $ex->publish($orderJson, "order.submit", AMQP_NOPARAM,
                array("Content-type" => "text/json"));