for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace OldSound\RabbitMqBundle\RabbitMq;
use PhpAmqpLib\Channel\AMQPChannel;
/**
* AMQPLoggedChannel.
*
* @author Marc Weistroff <[email protected]>
*/
class AMQPLoggedChannel extends AMQPChannel
{
private $basicPublishLog = [];
public function basic_publish($msg, $exchange = '', $routingKey = '', $mandatory = false, $immediate = false, $ticket = null)
$this->basicPublishLog[] = [
'msg' => $msg,
'exchange' => $exchange,
'routing_key' => $routingKey,
'mandatory' => $mandatory,
'immediate' => $immediate,
'ticket' => $ticket,
];
parent::basic_publish($msg, $exchange, $routingKey, $mandatory, $immediate, $ticket);
}
public function getBasicPublishLog()
return $this->basicPublishLog;
php-amqplib /
RabbitMqBundle
