TaskQueue::done() - Code Metrics - Inspection of "feat(judge): add solution queue" - hustoj/hustoj-neo - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( b0764c...fc8584 )

by he

created 2019-09-04 15:56 UTC

TaskQueue::done() A

↳ Parent: TaskQueue

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	2
c	0
b	0
f	0
nc	1
nop	0
dl	0
loc	4
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();
    }

    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!', $e->getMessage());
            app('log')->error('add task queue failed!', /** @scrutinizer ignore-type */ $e->getMessage());
        }

    }

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

    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;
    }

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

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

        return $message;
    }
}


hustoj / hustoj-neo

Push — master ( b0764c...fc8584 )

TaskQueue::done() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like