markdunphy/ears

A PHP RabbitMQ library using php-amqplib

Ears

A PHP RabbitMQ library using php-amqplib, _(*1)

Basic Usage

These examples use the default localhost RabbitMQ server created when you install it. For production use (and you're crazy if you're doing this), you should configure a markdunphy\Ears\Connection object to pass in as the first argument to the markdunphy\Ears\Ears constructor., _(*2)

Below is a simple hello world demonstration. Run the consumer code in one terminal tab and the publisher in another to watch things happen., _(*3)

Configuring a Consumer

use \markdunphy\Ears\Ears;

$consumer = ( new Ears )->getConsumer();

$consumer->consumeBasic( 'hello', function( $message ) {
  echo $message->body . "\n";
} );

Configuring a Publisher

use \markdunphy\Ears\Ears;

$ears = new Ears( null, 'hello' );

$publisher = $ears->getPublisher();

$publisher->sendBasic( 'Hello world' );