OldSound\RabbitMqBundle\EventListener\PcntlSignalDispatchSubscriber

Complexity

Total Complexity

5

Size/Duplication

Total Lines	34
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getSubscribedEvents()	0	5	1
A	afterProcessingMessages()	0	3	1
A	__construct()	0	13	2
A	onConsume()	0	3	1

<?php


namespace OldSound\RabbitMqBundle\EventListener;

use OldSound\RabbitMqBundle\Event\AfterProcessingMessagesEvent;
use OldSound\RabbitMqBundle\Event\OnConsumeEvent;
use OldSound\RabbitMqBundle\RabbitMq\Consumer;
use PhpAmqpLib\Exception\AMQPTimeoutException;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class PcntlSignalDispatchSubscriber implements EventSubscriberInterface
{
    public static function getSubscribedEvents()
    {
        return [
            OnConsumeEvent::NAME => 'onConsume',
            AfterProcessingMessagesEvent::NAME => 'afterProcessingMessages'
        ];
    }

    public function __construct(Consumer $consumer)
    {
        $stopConsumer = function () use ($consumer) {
            // Process current message, then halt consumer
            $consumer->forceStopConsumer();
            // Halt consumer if waiting for a new message from the queue
            try {
                $consumer->stopConsuming(true);
            } catch (AMQPTimeoutException $e) {}

Consider adding a comment why this CATCH block is empty.

        };

        pcntl_signal(SIGTERM, $stopConsumer);
        pcntl_signal(SIGINT, $stopConsumer);
        // TODO pcntl_signal(SIGHUP, $restartConsumer);
    }

    public function onConsume(OnConsumeEvent $event)

The parameter $event is not used and could be removed.

    {
        pcntl_signal_dispatch();
    }

    public function afterProcessingMessages(AfterProcessingMessagesEvent $event)

The parameter $event is not used and could be removed.

    {
        pcntl_signal_dispatch();
    }
}