Ccovey\RabbitMQ\Connection\Connection

Complexity

Total Complexity

5

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	connect()	0	4	1
A	getChannel()	0	4	1
A	getStream()	0	23	2

<?php

namespace Ccovey\RabbitMQ\Connection;

use Ccovey\RabbitMQ\Channel;
use Ccovey\RabbitMQ\ChannelInterface;
use PhpAmqpLib\Connection\AMQPStreamConnection;

class Connection implements ConnectionInterface
{
    /**
     * @var ConnectionParameters
     */
    private $parameters;

    /**
     * @var AMQPStreamConnection
     */
    private $stream;

    public function __construct(ConnectionParameters $parameters)
    {
        $this->parameters = $parameters;
    }

    public function connect()
    {
        $this->getStream()->reconnect();
    }

    public function getChannel(string $channelId = '') : ChannelInterface
    {
        return new Channel($this->getStream()->channel($channelId));
    }

    protected function getStream()
    {
        if (!$this->stream) {
            $this->stream = new AMQPStreamConnection(
                $this->parameters->getHost(),
                $this->parameters->getPort(),
                $this->parameters->getUser(),
                $this->parameters->getPassword(),
                $this->parameters->getVhost(),
                $this->parameters->shouldInsist(),
                $this->parameters->getLoginMethod(),
                $this->parameters->getLoginResponse(),
                $this->parameters->getLocale(),
                $this->parameters->getConnectionTimeout(),
                $this->parameters->getReadWriteTimeout(),
                $this->parameters->getContext(),
                $this->parameters->shouldKeepalive(),
                $this->parameters->getHeartbeat()
            );
        }

        return $this->stream;
    }
}