WorkerQueueCallback::toClosure()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 8
Code Lines 4

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
dl 0
loc 8
rs 9.4285
c 0
b 0
f 0
cc 1
eloc 4
nc 1
nop 0
1
<?php
2
3
namespace Cmobi\RabbitmqBundle\Transport\Worker;
4
5
use Cmobi\RabbitmqBundle\Queue\QueueCallbackInterface;
6
use Cmobi\RabbitmqBundle\Queue\QueueServiceInterface;
7
use PhpAmqpLib\Message\AMQPMessage;
8
9
class WorkerQueueCallback implements QueueCallbackInterface
10
{
11
    private $queueService;
12
13
    public function __construct(QueueServiceInterface $queueService)
14
    {
15
        $this->queueService = $queueService;
16
    }
17
18
    /**
19
     * @return QueueServiceInterface
20
     */
21
    public function getQueueService()
22
    {
23
        return $this->queueService;
24
    }
25
26
    /**
27
     * @return \Closure
28
     */
29
    public function toClosure()
30
    {
31
        return function (AMQPMessage $message) {
32
            $this->getQueueService()->handle($message);
33
34
            $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);
0 ignored issues
show
Documentation introduced by
$message->delivery_info['delivery_tag'] is of type object<PhpAmqpLib\Channel\AMQPChannel>, but the function expects a string.

It seems like the type of the argument is not accepted by the function/method which you are calling.

In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug.

We suggest to add an explicit type cast like in the following example:

function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
Loading history...
35
        };
36
    }
37
}
38