RabbitMQQueueStatusGuzzleProvider::getApiQueueStatus()

Complexity

Conditions	2
Paths	2

Size

Total Lines

16

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function getApiQueueStatus()
    {
        if (!class_exists(GuzzleClient::class)) {
            throw new MonitoringException(
                'The guzzle http client library is required to run rabbitmq health checks. '
                .'Make sure to add guzzlehttp/guzzle to your composer.json.'
            );
        }

        $client = new GuzzleClient();
        $client->setConfig(['curl.options' => [CURLOPT_CONNECTTIMEOUT_MS => 3000]]);
        $request = $client->get(sprintf('%s/queues', $this->settings['console_url']));
        $request->setAuth($this->settings['user'], $this->settings['pass']);

        return json_decode($request->send()->getBody(true), true);
    }
}