App\Task\TaskQueue

Complexity

Total Complexity

7

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getConnection()	0	8	1
A	makeMessage()	0	8	1
A	done()	0	4	1
A	queueChannel()	0	6	1
A	add()	0	7	2

<?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();
    }
}