DeadQueue::getMessagesFromQueue()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 4
Code Lines 2

Duplication

Lines 0
Ratio 0 %

Importance

Changes 1
Bugs 0 Features 0
Metric Value
eloc 2
c 1
b 0
f 0
dl 0
loc 4
rs 10
cc 1
nc 1
nop 3
1
<?php
2
3
namespace LeoCarmo\RedisQueue;
4
5
use LeoCarmo\RedisQueue\Exceptions\QueueWithoutConnectionException;
6
7
class DeadQueue extends Queue
8
{
9
10
    /**
11
     * @param string $queue
12
     *
13
     * @throws QueueWithoutConnectionException
14
     */
15
    public static function restoreMessages(string $queue)
16
    {
17
        self::moveMessages(
18
            $queue,
19
            self::getDeadQueueName($queue),
20
            $queue
21
        );
22
    }
23
24
    /**
25
     * @param string $queue
26
     * @return int
27
     *
28
     * @throws QueueWithoutConnectionException
29
     */
30
    public static function removeMessagesFromQueue(string $queue)
31
    {
32
        return parent::removeMessages(
0 ignored issues
show
Bug Best Practice introduced by
The expression return parent::removeMes...tDeadQueueName($queue)) returns the type boolean which is incompatible with the documented return type integer.
Loading history...
33
            $queue, self::getDeadQueueName($queue)
34
        );
35
    }
36
37
    /**
38
     * @param string $queue
39
     * @return int
40
     *
41
     * @throws QueueWithoutConnectionException
42
     */
43
    public static function countMessagesInQueue(string $queue)
44
    {
45
        return parent::countMessages(
46
            $queue, self::getDeadQueueName($queue)
47
        );
48
    }
49
50
    /**
51
     * @param string $queue
52
     * @param int $start
53
     * @param int $end
54
     * @return array
55
     *
56
     * @throws QueueWithoutConnectionException
57
     */
58
    public static function getMessagesFromQueue(string $queue, int $start, int $end)
59
    {
60
        return parent::getMessages(
61
            $queue, self::getDeadQueueName($queue), $start, $end
62
        );
63
    }
64
}
65