TonicHealthCheck\Check\ActiveMQ\Connect\ActiveMQConnectCheck

Complexity

Total Complexity

5

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	performCheck()	0	8	2
A	getStatefulStomp()	0	4	1
A	setStatefulStomp()	0	4	1

<?php

namespace TonicHealthCheck\Check\ActiveMQ\Connect;

use Stomp\StatefulStomp as StatefulStomp;
use Stomp\Exception\StompException;
use TonicHealthCheck\Check\ActiveMQ\AbstractActiveMQCheck;

/**
 * Class ActiveMQConnectCheck.
 */
class ActiveMQConnectCheck extends AbstractActiveMQCheck
{
    const CHECK = 'activemq-connect-performCheck';

    const TEST_DESTINATION = '/queue/test';
    const TEST_BODY = 'test';
    const TEST_TIME_OUT = 10;

    /**
     * @var mixed
     */
    protected $statefulStomp;

    /**
     * @param string        $checkNode
     * @param mixed         $statefulStomp
     */
    public function __construct($checkNode, $statefulStomp)
    {
        parent::__construct($checkNode);
        $this->setStatefulStomp($statefulStomp);
    }

    /**
     * Check PactiveMQClient can to connect to activeMQ server.
     *
     * @throws ActiveMQConnectCheckException
     */
    public function performCheck()
    {
        try {
            $this->getStatefulStomp()->getClient()->connect();
        } catch (StompException $e) {
            throw  ActiveMQConnectCheckException::connectProblem($e);
        }
    }

    /**
     * @return StatefulStomp
     */
    public function getStatefulStomp()
    {
        return $this->statefulStomp;
    }

    /**
     * @param StatefulStomp $statefulStomp
     */
    protected function setStatefulStomp(StatefulStomp $statefulStomp)
    {
        $this->statefulStomp = $statefulStomp;
    }
}