Bernard\EventListener\LoggerSubscriber

Complexity

Total Complexity

5

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Test Coverage

Coverage

78.13%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	onProduce()	0	7	1
A	onInvoke()	0	6	1
A	onReject()	0	7	1
A	getSubscribedEvents()	0	8	1

<?php

namespace Bernard\EventListener;

use Bernard\Event\EnvelopeEvent;
use Bernard\Event\RejectEnvelopeEvent;
use Psr\Log\LoggerInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class LoggerSubscriber implements EventSubscriberInterface
{
    protected $logger;

    /**
     * @param LoggerInterface $logger
     */
    public function __construct(LoggerInterface $logger)
    {
        $this->logger = $logger;
    }

    /**
     * @param EnvelopeEvent $event
     */
    public function onProduce(EnvelopeEvent $event)
    {
        $this->logger->info('[bernard] produced {envelope} onto {queue}.', [
            'envelope' => $event->getEnvelope(),
            'queue' => $event->getQueue(),
        ]);
    }

    /**
     * @param EnvelopeEvent $event
     */
    public function onInvoke(EnvelopeEvent $event)
    {
        $this->logger->info('[bernard] invoking receiver for {envelope}.', [
            'envelope' => $event->getEnvelope(),
        ]);
    }

    /**
     * @param RejectEnvelopeEvent $event
     */
    public function onReject(RejectEnvelopeEvent $event)
    {
        $this->logger->error('[bernard] caught exception {exception} while processing {envelope}.', [
            'envelope' => $event->getEnvelope(),
            'exception' => $event->getException(),
        ]);
    }

    /**
     * @return array
     */
    public static function getSubscribedEvents()
    {
        return [
            'bernard.produce' => ['onProduce'],
            'bernard.invoke' => ['onInvoke'],
            'bernard.reject' => ['onReject'],
        ];
    }
}