Innmind\AMQP\Client\Channel\Transaction\Transaction

Complexity

Total Complexity

4

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	select()	0	10	1
A	commit()	0	10	1
A	rollback()	0	10	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Client\Channel\Transaction;

use Innmind\AMQP\{
    Client\Channel\Transaction as TransactionInterface,
    Transport\Connection,
    Transport\Frame\Channel,
};

final class Transaction implements TransactionInterface
{
    private $connection;
    private $channel;

    public function __construct(Connection $connection, Channel $channel)
    {
        $this->connection = $connection;
        $this->channel = $channel;
    }

    public function select(): TransactionInterface
    {
        $this
            ->connection
            ->send($this->connection->protocol()->transaction()->select(
                $this->channel
            ))
            ->wait('tx.select-ok');

        return $this;
    }

    public function commit(): TransactionInterface
    {
        $this
            ->connection
            ->send($this->connection->protocol()->transaction()->commit(
                $this->channel
            ))
            ->wait('tx.commit-ok');

        return $this;
    }

    public function rollback(): TransactionInterface
    {
        $this
            ->connection
            ->send($this->connection->protocol()->transaction()->rollback(
                $this->channel
            ))
            ->wait('tx.rollback-ok');

        return $this;
    }
}