Remi's RPM repository - Blog

Commentaires

1. Le samedi 10 mars 2012, 12:40 par Remi

Minimal example : send a message

<?php
$message = "Test message at ".date("c");

// connect
$connection = new AMQPConnection();
$connection->connect();

$channel = new AMQPChannel($connection);

// setup exchange
$ex = new AMQPExchange($channel);

// Publish a message to the exchange with our routing key
$ex->publish($message, 'foo');

// disconnect
$connection->disconnect();
?>

Minimal example : retrieve a message

<?php
/* Create a connection using all default credentials: */
$connection = new AMQPConnection();
$connection->connect();

$channel = new AMQPChannel($connection);

/* create a queue object */
$queue = new AMQPQueue($channel);

//declare the queue
$queue->setName('foo');
$queue->setFlags(0);
$queue->declare();

//get the next message
$message = $queue->get(AMQP_AUTOACK);

if ($message) {
    echo "Message: ".$message->getBody()."\n";
} else {
    echo "No message\n";
}
?>

2. Le samedi 10 mars 2012, 13:12 par Remi

Review request for official repositories : Review #802037

3. Le jeudi 2 août 2012, 08:18 par Remi

Update to 1.0.4.

4. Le lundi 27 août 2012, 16:59 par Remi

Update to 1.0.5

5. Le mercredi 13 mars 2013, 09:28 par Remi

Update to 1.0.9 with librabbitmq 0.3.0