Puzzle\AMQP\Contexts\AbstractRabbitMQContext

Complexity

Total Complexity

3

Size/Duplication

Total Lines	31
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	host()	0	4	1
A	vhost()	0	4	1

<?php

namespace Puzzle\AMQP\Contexts;

use Behat\Behat\Context\Context;
use Puzzle\Configuration\Yaml;
use Gaufrette\Filesystem;
use Gaufrette\Adapter\Local;
use RabbitMQ\Management\APIClient;
use Puzzle\AMQP\Clients\Pecl;

abstract class AbstractRabbitMQContext implements Context
{
    const
        TEXT_ROUTING_KEY = 'text.key',
        JSON_ROUTING_KEY = 'json.key';
    
    protected
        $api,
        $exchange,
        $client,
        $configuration;
    
    public function __construct($path)
    {
        $this->configuration = new Yaml(new Filesystem(new Local($path)));
        $this->exchange = 'puzzle';
    
        $this->api = APIClient::factory(['host' => $this->host()]);
        $this->client = new Pecl($this->configuration);
    }
    
    private function host()
    {
        return $this->configuration->readRequired('amqp/broker/host');
    }
    
    protected function vhost()
    {
        return $this->configuration->readRequired('amqp/broker/vhost');
    }
}