for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Tomaj\Hermes\Driver;
use Closure;
use Exception;
use Tomaj\Hermes\MessageInterface;
use Tomaj\Hermes\MessageSerializer;
use PhpAmqpLib\Message\AMQPMessage;
use PhpAmqpLib\Channel\AMQPChannel;
class RabbitMqDriver implements DriverInterface
{
use SerializerAwareTrait;
/**
* @var AMQPChannel
*/
private $channel;
* @var string
private $queue;
* Create new RabbitMqDriver with provided channel.
*
* You have to create connection to rabbit, and setup queue outside of this class.
* Handling connection to rabbit is up to you and you have to manage it.
* @see examples/rabbitmq folder
* @param AMQPChannel $channel
* @param string $queue
public function __construct(AMQPChannel $channel, $queue)
$this->channel = $channel;
$this->queue = $queue;
$this->serializer = new MessageSerializer();
}
* {@inheritdoc}
public function send(MessageInterface $message)
$rabbitMessage = new AMQPMessage($this->serializer->serialize($message));
$this->channel->basic_publish($rabbitMessage, '', $this->queue);
public function wait(Closure $callback)
$this->channel->basic_consume(
$this->queue,
'',
false,
true,
function ($rabbitMessage) use ($callback) {
$message = $this->serializer->unserialize($rabbitMessage->body);
$callback($message);
$rabbitMessage->delivery_info['channel']->basic_ack($rabbitMessage->delivery_info['delivery_tag']);
);
while (count($this->channel->callbacks)) {
$this->channel->wait();
tomaj /
hermes
