Dekalee\RedisSwarrot\MessageProvider\RedisMessageProvider

Complexity

Total Complexity

7

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	get()	0	12	2
A	ack()	0	3	1
A	nack()	0	6	2
A	getQueueName()	0	4	1

<?php

namespace Dekalee\RedisSwarrot\MessageProvider;

use Swarrot\Broker\Message;
use Swarrot\Broker\MessageProvider\MessageProviderInterface;

/**
 * Class RedisMessageProvider
 */
class RedisMessageProvider implements MessageProviderInterface
{
    private $channel;
    private $queueName;

    /**
     * @param \Redis $channel
     * @param string $queueName
     */
    public function __construct(\Redis $channel, $queueName)
    {
        $this->channel = $channel;
        $this->queueName = $queueName;
    }

    /**
     * get.
     *
     * @return Message|null
     */
    public function get()
    {
        if (0 == $this->channel->lLen($this->getQueueName())) {
            return null;
        }

        list($channel, $json) = $this->channel->brPop($this->getQueueName(), 0);

        $message = new Message($json, ['channel' => $channel]);

        return $message;
    }

    /**
     * ack.
     *
     * @param Message $message
     */
    public function ack(Message $message)
    {
    }

    /**
     * nack.
     *
     * @param Message $message The message to NACK
     * @param bool    $requeue Requeue the message in the queue ?
     */
    public function nack(Message $message, $requeue = false)
    {
        if ($requeue) {
            $this->channel->lPush($this->getQueueName(), $message->getBody());
        }
    }

    /**
     * getQueueName.
     *
     * @return string
     */
    public function getQueueName()
    {
        return $this->queueName;
    }
}