Actuator\Health\Indicator\AMQPConnectionHealthIndicator

Complexity

Total Complexity

3

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	doHealthCheck()	0	13	2

<?php

namespace Actuator\Health\Indicator;

use Actuator\Health\HealthBuilder;
use PhpAmqpLib\Connection\AbstractConnection;

/**
 * Simple implementation of a HealthIndicator returning status information for
 * an AMQP Connection.
 *
 * @package Actuator\Health\Indicator
 */
class AMQPConnectionHealthIndicator extends AbstractHealthIndicator
{
    /**
     * @var AbstractConnection
     */
    private $connection;

    /**
     * MemcacheHealthIndicator constructor.
     * @param AbstractConnection $connection
     */
    public function __construct(AbstractConnection $connection)
    {
        $this->connection = $connection;
    }

    /**
     * Actual health check logic.
     *
     * @param HealthBuilder $builder
     * @throws \Exception any Exception that should create a Status::DOWN
     * system status.
     */
    protected function doHealthCheck(HealthBuilder $builder)
    {
        try {
            $this->connection->reconnect();
            $serverProperties = $this->connection->getServerProperties();
            $builder->withDetail('version', $serverProperties['version'][1]);
        } catch (\Exception $e) {
            $builder->down($e);
            return;
        }

        $builder->up();
    }
}