for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Puzzle\AMQP\Clients\Processors;
use Puzzle\AMQP\Messages\Processor;
use Puzzle\AMQP\WritableMessage;
trait MessageProcessorAware
{
private
$messageProcessors = [];
public function addMessageProcessor(Processor $processor)
$this->messageProcessors[] = $processor;
return $this;
}
private function onPublish(WritableMessage $message)
foreach($this->messageProcessors as $messageProcessor)
$messageProcessor->onPublish($message);
puzzle-org /
amqp
