for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Puzzle\AMQP\Workers;
use Swarrot\Processor\ProcessorInterface;
use Puzzle\Pieces\EventDispatcher\NullEventDispatcher;
use Puzzle\Pieces\EventDispatcher\EventDispatcherAware;
use Puzzle\AMQP\Clients\Processors\MessageProcessorAware;
class ProcessorInterfaceAdapter implements ProcessorInterface
{
use
EventDispatcherAware,
MessageProcessorAware;
private
$messageAdapterFactory,
$workerContext;
public function __construct(WorkerContext $workerContext, MessageAdapterFactory $factory = null)
$this->workerContext = $workerContext;
$this->eventDispatcher = new NullEventDispatcher();
if(! $factory instanceof MessageAdapterFactory)
$factory = new MessageAdapterFactory();
}
$this->messageAdapterFactory = $factory;
public function process(\Swarrot\Broker\Message $message, array $options)
$message = $this->messageAdapterFactory->build($message);
$message = $this->onConsume($message);
$this->workerContext->getLogger()->debug((string) $message);
$this->onWorkerProcess();
try
$processResult = $this->workerContext->getWorker()->process($message);
catch(\Exception $exception)
$this->onWorkerProcessed();
throw $exception;
return $processResult;
private function onWorkerProcess()
$this->eventDispatcher->dispatch('worker.process');
private function onWorkerProcessed()
$this->eventDispatcher->dispatch('worker.processed');
puzzle-org /
amqp
