TreeHouse\Queue\Amqp\Driver\Amqp\Channel

Complexity

Total Complexity

16

Size/Duplication

Total Lines	104
Duplicated Lines	38.46 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

79.41%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getConnection()	0	4	1
A	getChannelId()	0	4	1
A	basicQos()	10	10	3
A	startTransaction()	10	10	3
A	commitTransaction()	10	10	3
A	rollbackTransaction()	10	10	3
A	getDelegate()	0	4	1

<?php

namespace TreeHouse\Queue\Amqp\Driver\Amqp;

use TreeHouse\Queue\Amqp\ChannelInterface;
use TreeHouse\Queue\Amqp\ConnectionInterface;
use TreeHouse\Queue\Exception\ChannelException;
use TreeHouse\Queue\Exception\ConnectionException;

class Channel implements ChannelInterface
{
    /**
     * @var \AMQPChannel
     */
    protected $delegate;

    /**
     * @var ConnectionInterface
     */
    protected $connection;

    /**
     * @param \AMQPChannel        $delegate
     * @param ConnectionInterface $connection
     */
    public function __construct(\AMQPChannel $delegate, ConnectionInterface &$connection)
    {
        $this->delegate = $delegate;
        $this->connection = &$connection;
    }

    /**
     * @inheritdoc
     */
    public function getConnection()
    {
        return $this->connection;
    }

    /**
     * @inheritdoc
     */
    public function getChannelId()
    {
        return $this->delegate->getChannelId();
    }

    /**
     * @inheritdoc
     */
    public function basicQos($prefetchSize, $prefetchCount)

This method seems to be duplicated in your project.

    {
        try {
            return $this->delegate->qos($prefetchSize, $prefetchCount);
        } catch (\AMQPChannelException $e) {
            throw new ChannelException($e->getMessage(), $e->getCode(), $e);
        } catch (\AMQPConnectionException $e) {
            throw new ConnectionException($e->getMessage(), $e->getCode(), $e);
        }
    }

    /**
     * @inheritdoc
     */
    public function startTransaction()

This method seems to be duplicated in your project.

    {
        try {
            return $this->delegate->startTransaction();
        } catch (\AMQPChannelException $e) {
            throw new ChannelException($e->getMessage(), $e->getCode(), $e);
        } catch (\AMQPConnectionException $e) {
            throw new ConnectionException($e->getMessage(), $e->getCode(), $e);
        }
    }

    /**
     * @inheritdoc
     */
    public function commitTransaction()

This method seems to be duplicated in your project.

    {
        try {
            return $this->delegate->commitTransaction();
        } catch (\AMQPChannelException $e) {
            throw new ChannelException($e->getMessage(), $e->getCode(), $e);
        } catch (\AMQPConnectionException $e) {
            throw new ConnectionException($e->getMessage(), $e->getCode(), $e);
        }
    }

    /**
     * @inheritdoc
     */
    public function rollbackTransaction()

This method seems to be duplicated in your project.

    {
        try {
            return $this->delegate->rollbackTransaction();
        } catch (\AMQPChannelException $e) {
            throw new ChannelException($e->getMessage(), $e->getCode(), $e);
        } catch (\AMQPConnectionException $e) {
            throw new ConnectionException($e->getMessage(), $e->getCode(), $e);
        }
    }

    /**
     * @inheritdoc
     *
     * @return \AMQPChannel
     */
    public function getDelegate()
    {
        return $this->delegate;
    }
}