ProcessMessages::__invoke() - Code Metrics - leocarmo/php-redis-queue - Measure and Improve Code Quality continuously with Scrutinizer

ProcessMessages::__invoke() A
last analyzed 2019-09-14 14:53 UTC

↳ Parent: ProcessMessages

Complexity

Conditions	3
Paths	3

Size

Total Lines	13
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	5
c	1
b	0
f	0
dl	0
loc	13
rs	10
cc	3
nc	3
nop	1

<?php

require '../vendor/autoload.php';

use LeoCarmo\RedisQueue\Listener;

$redis = new Redis();
$redis->connect('localhost');

//Listener::setDefaultQueueClient($redis);
Listener::setQueueClient('my-queue', $redis);

class ProcessMessages
{

    /**
     * @param $events
     * @throws Exception
     */
    public function __invoke($events)
    {
        foreach ($events as $event) {
            $event_decoded = json_decode($event);

            if ($event_decoded->something === 1) {
                // IMPORTANT: This exception on multiple events,
                // will send all events received by this worker to dead queue.
                // Use transactions or bulk inserts when using multiple events
                throw new \Exception('Fail, send to dead queue');
            }

            dump($event);
        }
    }
}

// If the worker crash, we need to restore the processing messages
Listener::restoreMessagesFromProcessingQueue('my-queue', 1);

$processor = new ProcessMessages();

while (true) {
    Listener::processMessages('my-queue', 1, 10, $processor);
}

1			<?php
2
3			require '../vendor/autoload.php';
4
5			use LeoCarmo\RedisQueue\Listener;
6
7			$redis = new Redis();
8			$redis->connect('localhost');
9
10			//Listener::setDefaultQueueClient($redis);
11			Listener::setQueueClient('my-queue', $redis);
12
13			class ProcessMessages
14			{
15
16			/**
17			* @param $events
18			* @throws Exception
19			*/
20			public function __invoke($events)
21			{
22			foreach ($events as $event) {
23			$event_decoded = json_decode($event);
24
25			if ($event_decoded->something === 1) {
26			// IMPORTANT: This exception on multiple events,
27			// will send all events received by this worker to dead queue.
28			// Use transactions or bulk inserts when using multiple events
29			throw new \Exception('Fail, send to dead queue');
30			}
31
32			dump($event);
33			}
34			}
35			}
36
37			// If the worker crash, we need to restore the processing messages
38			Listener::restoreMessagesFromProcessingQueue('my-queue', 1);
39
40			$processor = new ProcessMessages();
41
42			while (true) {
43			Listener::processMessages('my-queue', 1, 10, $processor);
44			}

leocarmo / php-redis-queue

ProcessMessages::__invoke() A last analyzed 2019-09-14 14:53 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

ProcessMessages::__invoke() A
last analyzed 2019-09-14 14:53 UTC