Tvi\MonitorBundle\Check\rabbitmq\QueueConsumer\Check

Complexity

Total Complexity

6

Size/Duplication

Total Lines	90
Duplicated Lines	0 %

Test Coverage

Coverage

60%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	check()	0	25	5
A	__construct()	0	21	1

<?php

/**
 * This file is part of the `tvi/monitor-bundle` project.
 *
 * (c) https://github.com/turnaev/monitor-bundle/graphs/contributors
 *
 * For the full copyright and license information, please view the LICENSE.md
 * file that was distributed with this source code.
 */

PHP version not specified

Missing @category tag in file comment

Missing @package tag in file comment

Missing @author tag in file comment

Missing @license tag in file comment

Missing @link tag in file comment

namespace Tvi\MonitorBundle\Check\rabbitmq\QueueConsumer;

use JMS\Serializer\Annotation as JMS;
use Tvi\MonitorBundle\Check\rabbitmq\RabbitMQClient;
use Tvi\MonitorBundle\Check\CheckAbstract;
use ZendDiagnostics\Result\Failure;
use ZendDiagnostics\Result\Success;

/**

Missing short description in doc comment

 * @JMS\ExclusionPolicy("all")
 *
 * @author Vladimir Turnaev <turnaev@gmail.com>
 */

Missing @category tag in class comment

Missing @package tag in class comment

Missing @license tag in class comment

Missing @link tag in class comment

class Check extends CheckAbstract
{
    /**
     * Count that will cause a warning.
     *
     * @var int
     */
    protected $warningThreshold;

    /**
     * Count that will cause a fail.
     *
     * @var int
     */
    protected $criticalThreshold;

    /**
     * check queue name.

Doc comment short description must start with a capital letter

     *
     * @var string
     */
    protected $queue;

    /**

Missing short description in doc comment

     * @var RabbitMQClient
     */
    private $client;

Private member variable "client" must be prefixed with an underscore

    /**

Missing short description in doc comment

     * @param ?string $queue

Missing parameter comment

     * @param ?int    $criticalThreshold

Missing parameter comment

     * @param ?int    $warningThreshold

Missing parameter comment

     * @param ?string $host

Missing parameter comment

     * @param ?int    $port

Missing parameter comment

     * @param ?string $user

Missing parameter comment

     * @param ?string $password

Missing parameter comment

     * @param ?string $vhost

Missing parameter comment

     * @param ?string $dsn

Missing parameter comment

     */
    public function __construct(
        $queue,
        $criticalThreshold,
        $warningThreshold = null,
        $host = 'localhost',
        $port = 5672,
        $user = 'guest',
        $password = 'guest',
        $vhost = '/',
        $dsn = null)

The closing parenthesis of a multi-line function declaration must be on a new line

    {

The closing parenthesis and the opening brace of a multi-line function declaration must be on the same line

        $this->queue = $queue;
        $this->criticalThreshold = $criticalThreshold;
        $this->warningThreshold = $warningThreshold;

        $this->client = new RabbitMQClient($host,

The opening parenthesis of a multi-line function call should be the last content on the line.

            $port,
            $user,
            $password,
            $vhost,
            $dsn);

This line of the multi-line function call does not seem to be indented correctly. Expected 8 spaces, but found 12.

For multi-line function calls, the closing parenthesis should be on a new line.

    }

    /**
     * {@inheritdoc}
     */

Missing @return tag in function comment

    public function check()
    {
        try {
            $conn = $this->client->getConnect();
            $conn->channel();

            $channel = $conn->channel();

            list($queue, $messageCount, $consumerCount) = $channel->queue_declare($this->queue, true);

            if ($consumerCount <= $this->criticalThreshold) {
                $msg = sprintf('Consumer(s) %d got queue to few less them critical level %d.', $consumerCount, $this->criticalThreshold);

                return new Failure($msg, $messageCount);
            }

            if ($this->warningThreshold != null && $consumerCount <= $this->warningThreshold) {
                $msg = sprintf('Consumer(s) %d got queue to few less them critical level %d.', $consumerCount, $this->warningThreshold);

                return new Warning($msg, $messageCount);

The type Tvi\MonitorBundle\Check\rabbitmq\QueueConsumer\Warning was not found. Maybe you did not declare it correctly or list all dependencies?

            }

            return new Success(sprintf('Consumer(s) %d for queue.', $consumerCount), $consumerCount);
        } catch (\Exception $e) {
            return new Failure($e->getMessage());
        }
    }
}