Bernard\Driver\InteropDriver

Complexity

Total Complexity

14

Size/Duplication

Total Lines	121
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	1
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	listQueues()	0	4	1
A	createQueue()	0	3	1
A	countMessages()	0	4	1
A	pushMessage()	0	7	1
A	popMessage()	0	6	2
A	acknowledgeMessage()	0	4	1
A	peekQueue()	0	4	1
A	removeQueue()	0	3	1
A	info()	0	4	1
A	getQueueConsumer()	0	10	2
A	getContext()	0	4	1

<?php
namespace Bernard\Driver;

use Bernard\Driver;
use Interop\Queue\PsrConsumer;
use Interop\Queue\PsrContext;

final class InteropDriver implements Driver
{
    /**
     * @var PsrContext
     */
    private $context;

    /**
     * @var PsrConsumer[]
     */
    private $consumers;

    /**
     * @param PsrContext $context
     */
    public function __construct(PsrContext $context)
    {
        $this->context = $context;

        $this->consumers = [];
    }

    /**
     * {@inheritdoc}
     */
    public function listQueues()
    {
        return [];
    }

    /**
     * {@inheritdoc}
     */
    public function createQueue($queueName)
    {
    }

    /**
     * {@inheritdoc}
     */
    public function countMessages($queueName)
    {
        return 0;
    }

    /**
     * {@inheritdoc}
     */
    public function pushMessage($queueName, $message)
    {
        $queue = $this->context->createQueue($queueName);
        $message = $this->context->createMessage($message);

        $this->context->createProducer()->send($queue, $message);
    }

    /**
     * {@inheritdoc}
     */
    public function popMessage($queueName, $duration = 5)
    {
        if ($message = $this->getQueueConsumer($queueName)->receive($duration * 1000)) {
            return [$message->getBody(), $message];
        }
    }

    /**
     * {@inheritdoc}
     */
    public function acknowledgeMessage($queueName, $receipt)
    {
        $this->getQueueConsumer($queueName)->acknowledge($receipt);
    }

    /**
     * {@inheritdoc}
     */
    public function peekQueue($queueName, $index = 0, $limit = 20)
    {
        return [];
    }

    /**
     * {@inheritdoc}
     */
    public function removeQueue($queueName)
    {
    }

    /**
     * {@inheritdoc}
     */
    public function info()
    {
        return [];
    }

    /**
     * @param string $queueName
     *
     * @return PsrConsumer
     */
    private function getQueueConsumer($queueName)
    {
        if (false == array_key_exists($queueName, $this->consumers)) {

It seems like you are loosely comparing two booleans. Considering using the strict comparison === instead.

            $queue = $this->context->createQueue($queueName);

            $this->consumers[$queueName] = $this->context->createConsumer($queue);
        }

        return $this->consumers[$queueName];
    }

    /**
     * @return PsrContext
     */
    public function getContext()
    {
        return $this->context;
    }
}