AmqpWorkers\Loggable\LoggableWorker

Complexity

Total Complexity

2

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	1

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__invoke()	0	8	1

<?php

namespace AmqpWorkers\Loggable;

use AmqpWorkers\Worker\WorkerInterface;
use Psr\Log\LoggerInterface;

class LoggableWorker implements WorkerInterface
{
    /**
     * @var LoggerInterface
     */
    private $logger;
    /**
     * @var WorkerInterface
     */
    private $worker;

    /**
     * LoggableWorker constructor.
     *
     * @param LoggerInterface $logger
     * @param WorkerInterface $worker
     */
    public function __construct(LoggerInterface $logger, WorkerInterface $worker)
    {
        $this->logger = $logger;
        $this->worker = $worker;
    }

    /**
     * @param $message
     *
     * @return mixed
     */
    public function __invoke($message)
    {
        $this->logger->debug('Got "%s" message');
        $result = call_user_func($this->worker, $message);
        $this->logger->debug('Successfully handled "%s" message', $message);

        return $result;
    }
}