Abstract some Message Queuing system using the Adapter pattern
This is a work in progress and unfinished business!
producer.php
<?php
require_once 'autoload.php';
use Symfony\Component\EventDispatcher\EventDispatcher;
use BarbeQ\BarbeQ;
use BarbeQ\Adapter\AmqpAdapter;
use BarbeQ\Model\Message;
$messageDispatcher = new EventDispatcher();
$dispatcher = new EventDispatcher();
$connection = array('host' => 'localhost');
$exchange = array('name' => 'test_direct');
$queues = array(array('name' => 'test'));
$adapter = new AmqpAdapter($connection, $exchange, $queues);
$barbeQ = new BarbeQ($adapter, $messageDispatcher, $dispatcher);
$barbeQ->cook('test', new Message(array(
'id' => 1,
'foo' => 'bar',
)));
// or $barbeQ->publish(...), same action
consumer.php
<?php
require_once 'autoload.php';
use Symfony\Component\EventDispatcher\EventDispatcher;
use BarbeQ\Adapter\AmqpAdapter;
use BarbeQ\BarbeQ;
use Acme\PocBundle\Consumer\TestConsumer;
$messageDispatcher = new EventDispatcher();
$dispatcher = new EventDispatcher();
$connection = array('host' => 'localhost');
$exchange = array('name' => 'test_direct');
$queues = array(array('name' => 'test'));
$adapter = new AmqpAdapter($connection, $exchange, $queues);
$barbeQ = new BarbeQ($adapter, $messageDispatcher, $dispatcher);
$testConsumer = new TestConsumer();
$barbeQ->addConsumer('test', $testConsumer);
$barbeQ->eat('test', 5, function($i, MessageInterface $message) {
error_log(sprintf('For Iteration #%d, Memory: %s, Time: %0.04fs', $i, $message->getMemory(), $message->getTime()));
});