AmqpWorkers\Loggable\LoggableProducer

Complexity

Total Complexity

2

Size/Duplication

Total Lines	31
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	produce()	0	6	1

<?php

namespace AmqpWorkers\Loggable;

use AmqpWorkers\Exception\ProducerNotProperlyConfigured;
use AmqpWorkers\ProducerInterface;
use Psr\Log\LoggerInterface;

/**
 * This class is loggable implementation of Producer. It's just a decorator,
 * which delegates real producing into given implementation, and just logs all the events
 * @package AmqpWorkers\Loggable
 */
class LoggableProducer implements ProducerInterface
{

    /**
     * @var LoggerInterface
     */
    private $logger;
    /**
     * @var ProducerInterface
     */
    private $producer;

    public function __construct(LoggerInterface $logger, ProducerInterface $producer)
    {
        $this->logger = $logger;
        $this->producer = $producer;
    }

    /**
     * @param mixed $payload
     *
     * @todo: maybe add properties array as second parameter
     * @throws ProducerNotProperlyConfigured if queue nor exchange not given.
     */
    public function produce($payload)
    {
        $this->logger->debug('Got "%s" message, producing...', serialize($payload));

serialize($payload) is of type string, but the function expects a array.

        $this->producer->produce($payload);
        $this->logger->deubg('Produced "%s" message', serialize($payload));

The method deubg() does not seem to exist on object<Psr\Log\LoggerInterface>.

    }
}