Puzzle\AMQP\Consumers\AbstractConsumer

Complexity

Total Complexity

5

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

12%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	consume()	0	7	1
A	setMessageProvider()	0	4	1
A	getBaseStack()	0	9	1
A	getSwarrotConsumer()	0	9	1

<?php

namespace Puzzle\AMQP\Consumers;

use Puzzle\AMQP\Consumer;
use Swarrot\Broker\MessageProvider\PeclPackageMessageProvider;
use Swarrot\Consumer as SwarrotConsumer;
use Swarrot\Processor\Stack;
use Swarrot\Processor\ProcessorInterface;
use Psr\Log\NullLogger;
use Psr\Log\LoggerAwareTrait;
use Puzzle\AMQP\Client;
use Puzzle\AMQP\Workers\WorkerContext;

abstract class AbstractConsumer implements Consumer
{
    use LoggerAwareTrait;

    protected
        $messageProvider;

The visibility should be declared for property $messageProvider.

    private
        $client,

The visibility should be declared for property $client.

        $processor,
        $workerContext;

    public function __construct()
    {
        $this->logger = new NullLogger();
    }

    public function consume(ProcessorInterface $processor, Client $client, WorkerContext $workerContext)
    {
        $this->processor = $processor;
        $this->client = $client;
        $this->workerContext = $workerContext;
        $this->setMessageProvider();
    }

    private function setMessageProvider()
    {
        $this->messageProvider = new PeclPackageMessageProvider($this->client->getQueue($this->workerContext->queue));
    }

    protected function getBaseStack()
    {
        $stack = (new Stack\Builder())
            ->push('Swarrot\Processor\SignalHandler\SignalHandlerProcessor', $this->logger)
            ->push('Swarrot\Processor\ExceptionCatcher\ExceptionCatcherProcessor', $this->logger)
        ;

        return $stack;
    }

    protected function getSwarrotConsumer(Stack\Builder $stack)
    {
        return new SwarrotConsumer(
            $this->messageProvider,
            $stack->resolve($this->processor),
            null,
            $this->logger
        );
    }
}