for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
/*
* This file is part of the Sonata Project package.
*
* (c) Thomas Rabaix <[email protected]>
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace Sonata\NotificationBundle\Service;
use Guzzle\Http\Client as GuzzleClient;
use Sonata\NotificationBundle\Exception\MonitoringException;
/**
* @deprecated since version up 3.5.1 (created for BC). Use Sonata\NotificationBundle\Service\RabbitMQQueueStatusHttpProvider instead
* NEXT_MAJOR: remove this and use Sonata\NotificationBundle\Service\RabbitMQQueueStatusHttpProvider
* @author Nikolay Mitrofanov <[email protected]>
final class RabbitMQQueueStatusGuzzleProvider implements RabbitMQQueueStatusProviderInterface
{
* @var array
private $connectionSettings;
public function __construct(array $settings)
$this->connectionSettings = $settings;
}
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->connectionSettings['console_url']));
$request->setAuth($this->connectionSettings['user'], $this->connectionSettings['pass']);
return json_decode($request->send()->getBody(true), true);
sonata-project /
SonataNotificationBundle
