tavii / SQSJobQueueBundle

Queue.php

<?php
namespace Tavii\SQSJobQueueBundle;

use Symfony\Component\EventDispatcher\EventDispatcher;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Tavii\SQSJobQueue\Job\JobInterface;
use Tavii\SQSJobQueue\Message\MessageInterface;
use Tavii\SQSJobQueue\Queue\QueueInterface;
use Tavii\SQSJobQueue\Queue\QueueName;
use Tavii\SQSJobQueueBundle\Event\ReceiveQueueEvent;
use Tavii\SQSJobQueueBundle\Event\SentQueueEvent;

class Queue implements QueueInterface
{

    /**
     * @var Queue
     */
    private $baseQueue;

    /**
     * @var array
     */
    private $kernelOptions;

    /**
     * @var EventDispatcher
     */
    private $dispatcher;


    /**
     * Queue constructor.
     * @param QueueInterface $baseQueue
     * @param EventDispatcherInterface $dispatcher
     * @param array $kernelOptions
     */
    public function __construct(QueueInterface $baseQueue, EventDispatcherInterface $dispatcher, array $kernelOptions)
    {
        $this->baseQueue = $baseQueue;

$baseQueue is of type object<Tavii\SQSJobQueue\Queue\QueueInterface>, but the property $baseQueue was declared to be of type object<Tavii\SQSJobQueueBundle\Queue>. Are you sure that you always receive this specific sub-class here, or does it make sense to add an instanceof check?

        $this->kernelOptions = $kernelOptions;
        $this->dispatcher = $dispatcher;

$dispatcher is of type object<Symfony\Component\EventDispatcher\EventDispatcherInterface>, but the property $dispatcher was declared to be of type object<Symfony\Component\EventDispatcher\EventDispatcher>. Are you sure that you always receive this specific sub-class here, or does it make sense to add an instanceof check?

    }

    /**
     * {@inheritdoc}
     */
    public function receive(QueueName $queueName)
    {
        $message = $this->baseQueue->receive($queueName);
        if ($message instanceof MessageInterface) {
            $job = $message->getJob();
            if ($job instanceof ContainerAwareJob) {
                $job->setKernelOptions($this->kernelOptions);
            }
            $this->dispatcher->dispatch(SQSJobQueueEvents::QUEUE_RECEIVED, new ReceiveQueueEvent($message));
            return $message;
        }
        return null;
    }

    /**
     * {@inheritdoc}
     */
    public function send(JobInterface $job)
    {
        if ($job instanceof ContainerAwareJob) {
            $job->setKernelOptions($this->kernelOptions);
        }
        $result = $this->baseQueue->send($job);
        $this->dispatcher->dispatch(SQSJobQueueEvents::QUEUE_SENT, new SentQueueEvent($job, $result));
        return $result;
    }

    /**
     * {@inheritdoc}
     */
    public function delete(MessageInterface $message)
    {
        $result = false;
        if ($this->baseQueue->delete($message)) {
            $job = $message->getJob();
            unset($job);
            $result = true;
        }
        return $result;
    }


}