PHPDaemon\Clients\AMQP\Driver\Exception\AMQPConnectionException

Complexity

Total Complexity

7

Size/Duplication

Total Lines	182
Duplicated Lines	44.51 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	couldNotConnect()	0	17	1
A	notOpen()	15	15	1
A	authenticationFailed()	16	16	1
A	handshakeFailed()	0	17	1
A	authorizationFailed()	17	17	1
A	heartbeatTimedOut()	18	18	1
A	closedUnexpectedly()	15	15	1

<?php

namespace PHPDaemon\Clients\AMQP\Driver\Exception;

use PHPDaemon\Clients\AMQP\Driver\ConnectionOptions;
use PHPDaemon\Clients\AMQP\Driver\Protocol\Exception\AMQPConnectionExceptionInterface;
use PHPDaemon\Clients\AMQP\Driver\Protocol\Exception\AMQPException;

/**
 * Class AMQPConnectionException
 * @author Aleksey I. Kuleshov YOU GLOBAL LIMITED
 * @package PHPDaemon\Clients\AMQP\Driver\Exception
 */
class AMQPConnectionException extends AMQPException implements AMQPConnectionExceptionInterface
{
    /**
     * Create an exception that indicates a failure to establish a connection to
     * an AMQP broker.
     *
     * @param ConnectionOptions $options The options used when establishing the connection.
     * @param string $description A description of the problem.
     * @param \Exception|null $previous The exception that caused this exception, if any.
     * @return AMQPConnectionException
     */
    public static function couldNotConnect(
        ConnectionOptions $options,
        $description,
        \Exception $previous = null
    )
    {
        return new self(
            sprintf(
                'Unable to connect to AMQP broker [%s:%d], check connection options and network connectivity (%s).',
                $options->getHost(),
                $options->getPort(),
                rtrim($description, '.')
            ),
            0,
            $previous
        );
    }

    /**
     * Create an exception that indicates an attempt to use a connection that has
     * already been closed.
     *
     * @param ConnectionOptions $options The options used when establishing the connection.
     * @param \Exception|null $previous The exception that caused this exception, if any.
     * @return AMQPConnectionException
     */
    public static function notOpen(

This method seems to be duplicated in your project.

        ConnectionOptions $options,
        \Exception $previous = null
    )
    {
        return new self(
            sprintf(
                'Unable to use connection to AMQP broker [%s:%d] because it is closed.',
                $options->getHost(),
                $options->getPort()
            ),
            0,
            $previous
        );
    }

    /**
     * Create an exception that indicates that the credentials specified in the
     * connection options are incorrect.
     *
     * @param ConnectionOptions $options The options used when establishing the connection.
     * @param \Exception|null $previous The exception that caused this exception, if any.
     * @return AMQPConnectionException
     */
    public static function authenticationFailed(

This method seems to be duplicated in your project.

        ConnectionOptions $options,
        \Exception $previous = null
    )
    {
        return new self(
            sprintf(
                'Unable to authenticate as "%s" on AMQP broker [%s:%d], check authentication credentials.',
                $options->getUsername(),
                $options->getHost(),
                $options->getPort()
            ),
            0,
            $previous
        );
    }

    /**
     * Create an exception that indicates a the AMQP handshake failed.
     *
     * @param ConnectionOptions $options The options used when establishing the connection.
     * @param string $description A description of the problem.
     * @param \Exception|null $previous The exception that caused this exception, if any.
     * @return AMQPConnectionException
     */
    public static function handshakeFailed(
        ConnectionOptions $options,
        $description,
        \Exception $previous = null
    )
    {
        return new self(
            sprintf(
                'Unable to complete handshake on AMQP broker [%s:%d], %s.',
                $options->getHost(),
                $options->getPort(),
                rtrim($description, '.')
            ),
            0,
            $previous
        );
    }

    /**
     * Create an exception that indicates that the credentials specified in the
     * connection options do not grant access to the requested AMQP virtual host.
     *
     * @param ConnectionOptions $options The options used when establishing the connection.
     * @param \Exception|null $previous The exception that caused this exception, if any.
     * @return AMQPConnectionException
     */
    public static function authorizationFailed(

This method seems to be duplicated in your project.

        ConnectionOptions $options,
        \Exception $previous = null
    )
    {
        return new self(
            sprintf(
                'Unable to access vhost "%s" as "%s" on AMQP broker [%s:%d], check permissions.',
                $options->getVhost(),
                $options->getUsername(),
                $options->getHost(),
                $options->getPort()
            ),
            0,
            $previous
        );
    }

    /**
     * Create an exception that indicates that the broker has failed to send
     * any data for a period longer than the heartbeat interval.
     *
     * @param ConnectionOptions $options The options used when establishing the connection.
     * @param int $heartbeatInterval The heartbeat interval negotiated during the AMQP handshake.
     * @param \Exception|null $previous The exception that caused this exception, if any.
     * @return AMQPConnectionException
     */
    public static function heartbeatTimedOut(

This method seems to be duplicated in your project.

        ConnectionOptions $options,
        $heartbeatInterval,
        \Exception $previous = null
    )
    {
        return new self(
            sprintf(
                'The AMQP connection with broker [%s:%d] has timed out, '
                . 'the last heartbeat was received over %d seconds ago.',
                $options->getHost(),
                $options->getPort(),
                $heartbeatInterval
            ),
            0,
            $previous
        );
    }

    /**
     * Create an exception that indicates an unexpected closure of the
     * connection to the AMQP broker.
     *
     * @param ConnectionOptions $options The options used when establishing the connection.
     * @param \Exception|null $previous The exception that caused this exception, if any.
     * @return AMQPConnectionException
     */
    public static function closedUnexpectedly(

This method seems to be duplicated in your project.

        ConnectionOptions $options,
        \Exception $previous = null
    )
    {
        return new self(
            sprintf(
                'The AMQP connection with broker [%s:%d] was closed unexpectedly.',
                $options->getHost(),
                $options->getPort()
            ),
            0,
            $previous
        );
    }
}