Connect::getChannel() - Code Metrics - WillRy/rabbitrun - Measure and Improve Code Quality continuously with Scrutinizer

Connect::getChannel() A
last analyzed 2025-03-22 01:03 UTC

↳ Parent: Connect

Complexity

Conditions	5
Paths	3

Size

Total Lines	11
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	5
eloc	6
nc	3
nop	0
dl	0
loc	11
rs	9.6111
c	0
b	0
f	0

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

            }
        }

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


1			<?php
2
3			namespace WillRy\RabbitRun\Connections;
4
5			use PhpAmqpLib\Channel\AMQPChannel;
6			use PhpAmqpLib\Connection\AMQPStreamConnection;
7
8			/**
9			* Class Connect Singleton Pattern
10			*/
11			class Connect
12			{
13			/**
14			* @const array
15			*/
16			private static $opt = [];
17
18			/** @var AMQPStreamConnection */
19			private static $instance;
20
21			/** @var AMQPChannel */
22			private static $channel;
23
24			/**
25			* Connect constructor. Private singleton
26			*/
27			private function __construct()
28			{
29			}
30
31			/**
32			* Connect clone. Private singleton
33			*/
34			private function __clone()
35			{
36			}
37
38			public static function getInstance()
39			{
40			if (empty(self::$instance) \|\| (!empty(self::$instance) && !self::$instance->isConnected())) {
41			self::$instance = new AMQPStreamConnection(
42			self::$opt["host"],
43			self::$opt["port"],
44			self::$opt["user"],
45			self::$opt["pass"]
46			);
47			}
48
49			return self::$instance;
50			}
51
52			public static function getChannel()
53			{
54			if (empty(self::$channel) \|\| (!empty(self::$channel) && !self::$channel->is_open())) {
55			try {
56			self::$channel = self::getInstance()->channel();
57			} catch (\Exception $exception) {
58			die('Connection error RabbitMQ' . $exception->getMessage());
			0 ignored issues – show Best Practice introduced 2023-08-26 22:55 UTC by Report Bug Copy Issue Report Using `exit` here is not recommended. In general, usage of exit should be done with care and only when running in a scripting context like a CLI script. Loading history...
59			}
60			}
61
62			return self::$channel;
63			}
64
65			public static function closeInstance()
66			{
67			if (!empty(self::$instance) && self::$instance->isConnected()) {
68			self::$instance->close();
69			}
70			}
71
72			public static function closeChannel()
73			{
74			if (!empty(self::$channel) && self::$channel->is_open()) {
75			self::$channel->close();
76			}
77			}
78
79			public static function config($host, $port, $user, $pass, $vhost)
80			{
81			self::$opt = [
82			'host' => $host,
83			'port' => $port,
84			'user' => $user,
85			'pass' => $pass,
86			'vhost' => $vhost,
87			];
88			}
89			}
90

WillRy / rabbitrun

Connect::getChannel() A last analyzed 2025-03-22 01:03 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Connect::getChannel() A
last analyzed 2025-03-22 01:03 UTC