WillRy\RabbitRun\Connections\Connect

Complexity

Total Complexity

18

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	closeChannel()	0	4	3
A	getInstance()	0	12	4
A	__construct()	0	2	1
A	config()	0	8	1
A	getChannel()	0	11	5
A	__clone()	0	2	1
A	closeInstance()	0	4	3

<?php

namespace WillRy\RabbitRun\Connections;

use PhpAmqpLib\Channel\AMQPChannel;
use PhpAmqpLib\Connection\AMQPStreamConnection;

/**
 * Class Connect Singleton Pattern
 */
class Connect
{
    /**
     * @const array
     */
    private static $opt = [];

    /** @var AMQPStreamConnection */
    private static $instance;

    /** @var AMQPChannel */
    private static $channel;

    /**
     * Connect constructor. Private singleton
     */
    private function __construct()
    {
    }

    /**
     * Connect clone. Private singleton
     */
    private function __clone()
    {
    }

    public static function getInstance()
    {
        if (empty(self::$instance) || (!empty(self::$instance) && !self::$instance->isConnected())) {
            self::$instance = new AMQPStreamConnection(
                self::$opt["host"],
                self::$opt["port"],
                self::$opt["user"],
                self::$opt["pass"]
            );
        }

        return self::$instance;
    }

    public static function getChannel()
    {
        if (empty(self::$channel) || (!empty(self::$channel) && !self::$channel->is_open())) {
            try {
                self::$channel = self::getInstance()->channel();
            } catch (\Exception $exception) {
                die('Connection error RabbitMQ' . $exception->getMessage());

Using exit here is not recommended.

            }
        }

        return self::$channel;
    }

    public static function closeInstance()
    {
        if (!empty(self::$instance) && self::$instance->isConnected()) {
            self::$instance->close();
        }
    }

    public static function closeChannel()
    {
        if (!empty(self::$channel) && self::$channel->is_open()) {
            self::$channel->close();
        }
    }

    public static function config($host, $port, $user, $pass, $vhost)
    {
        self::$opt = [
            'host' => $host,
            'port' => $port,
            'user' => $user,
            'pass' => $pass,
            'vhost' => $vhost,
        ];
    }
}