TaskQueue::add() - Code Metrics - hustoj/hustoj-neo - Measure and Improve Code Quality continuously with Scrutinizer

TaskQueue::add() A
last analyzed 2022-03-31 04:51 UTC

↳ Parent: TaskQueue

Complexity

Conditions	2
Paths	3

Size

Total Lines	7
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

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

<?php

namespace App\Task;

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Exception\AMQPRuntimeException;
use PhpAmqpLib\Message\AMQPMessage;

class TaskQueue
{
    private $connection;
    private $channel;

    public function __construct()
    {
        $this->connection = $this->getConnection();
        $this->channel = $this->queueChannel();
    }

    private function getConnection()
    {
        return new AMQPStreamConnection(
            config('rabbitmq.host'),
            config('rabbitmq.port'),
            config('rabbitmq.login'),
            config('rabbitmq.password'),
            config('rabbitmq.vhost')
        );
    }

    private function queueChannel()
    {
        $channel = $this->connection->channel();
        $channel->queue_declare(config('rabbitmq.queue'), false, true);

        return $channel;
    }

    public function add(Task $task)
    {
        try {
            $message = $this->makeMessage($task);
            $this->channel->basic_publish($message, '', config('rabbitmq.routing_key'));
        } catch (AMQPRuntimeException $e) {
            app('log')->error('add task queue failed!', ['message' => $e->getMessage()]);
        }
    }

    private function makeMessage(Task $task)
    {
        $content = json_encode($task->asQueueInfo());

        $message = new AMQPMessage();
        $message->setBody($content);

        return $message;
    }

    public function done()
    {
        $this->channel->close();
        $this->connection->close();
    }
}


1			<?php
2
3			namespace App\Task;
4
5			use PhpAmqpLib\Connection\AMQPStreamConnection;
6			use PhpAmqpLib\Exception\AMQPRuntimeException;
7			use PhpAmqpLib\Message\AMQPMessage;
8
9			class TaskQueue
10			{
11			private $connection;
12			private $channel;
13
14			public function __construct()
15			{
16			$this->connection = $this->getConnection();
17			$this->channel = $this->queueChannel();
18			}
19
20			private function getConnection()
21			{
22			return new AMQPStreamConnection(
23			config('rabbitmq.host'),
24			config('rabbitmq.port'),
25			config('rabbitmq.login'),
26			config('rabbitmq.password'),
27			config('rabbitmq.vhost')
28			);
29			}
30
31			private function queueChannel()
32			{
33			$channel = $this->connection->channel();
34			$channel->queue_declare(config('rabbitmq.queue'), false, true);
35
36			return $channel;
37			}
38
39			public function add(Task $task)
40			{
41			try {
42			$message = $this->makeMessage($task);
43			$this->channel->basic_publish($message, '', config('rabbitmq.routing_key'));
44			} catch (AMQPRuntimeException $e) {
45			app('log')->error('add task queue failed!', ['message' => $e->getMessage()]);
46			}
47			}
48
49			private function makeMessage(Task $task)
50			{
51			$content = json_encode($task->asQueueInfo());
52
53			$message = new AMQPMessage();
54			$message->setBody($content);
55
56			return $message;
57			}
58
59			public function done()
60			{
61			$this->channel->close();
62			$this->connection->close();
63			}
64			}
65

hustoj / hustoj-neo

TaskQueue::add() A last analyzed 2022-03-31 04:51 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

TaskQueue::add() A
last analyzed 2022-03-31 04:51 UTC