LeoCarmo\RedisQueue\DeadQueue

Complexity

Total Complexity

4

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	restoreMessages()	0	6	1
A	countMessagesInQueue()	0	4	1
A	getMessagesFromQueue()	0	4	1
A	removeMessagesFromQueue()	0	4	1

<?php

namespace LeoCarmo\RedisQueue;

use LeoCarmo\RedisQueue\Exceptions\QueueWithoutConnectionException;

class DeadQueue extends Queue
{

    /**
     * @param string $queue
     *
     * @throws QueueWithoutConnectionException
     */
    public static function restoreMessages(string $queue)
    {
        self::moveMessages(
            $queue,
            self::getDeadQueueName($queue),
            $queue
        );
    }

    /**
     * @param string $queue
     * @return int
     *
     * @throws QueueWithoutConnectionException
     */
    public static function removeMessagesFromQueue(string $queue)
    {
        return parent::removeMessages(

The expression return parent::removeMessages($queue, self::getDeadQueueName($queue)) returns the type boolean which is incompatible with the documented return type integer.

            $queue, self::getDeadQueueName($queue)
        );
    }

    /**
     * @param string $queue
     * @return int
     *
     * @throws QueueWithoutConnectionException
     */
    public static function countMessagesInQueue(string $queue)
    {
        return parent::countMessages(
            $queue, self::getDeadQueueName($queue)
        );
    }

    /**
     * @param string $queue
     * @param int $start
     * @param int $end
     * @return array
     *
     * @throws QueueWithoutConnectionException
     */
    public static function getMessagesFromQueue(string $queue, int $start, int $end)
    {
        return parent::getMessages(
            $queue, self::getDeadQueueName($queue), $start, $end
        );
    }
}