RabbitManagementExtensionTrait.php

<?php

namespace Enqueue\Test;

use Enqueue\Dsn\Dsn;

trait RabbitManagementExtensionTrait
{
    /**
     * @param string $queueName
     */
    private function removeQueue($queueName)
    {
        $dsn = Dsn::parseFirst(getenv('RABBITMQ_AMQP_DSN'));

        $url = sprintf(
            'http://%s:15672/api/queues/%s/%s',
            $dsn->getHost(),
            urlencode(ltrim($dsn->getPath(), '/')),
            $queueName
        );

        $ch = curl_init();
        curl_setopt($ch, \CURLOPT_URL, $url);
        curl_setopt($ch, \CURLOPT_CUSTOMREQUEST, 'DELETE');
        curl_setopt($ch, \CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, \CURLOPT_HTTPAUTH, \CURLAUTH_BASIC);
        curl_setopt($ch, \CURLOPT_USERPWD, $dsn->getUser().':'.$dsn->getPassword());
        curl_setopt($ch, \CURLOPT_HTTPHEADER, [
            'Content-Type' => 'application/json',
        ]);
        curl_exec($ch);

        $httpCode = curl_getinfo($ch, \CURLINFO_HTTP_CODE);

        curl_close($ch);

        if (false == in_array($httpCode, [204, 404], true)) {
            throw new \LogicException('Failed to remove queue. The response status is '.$httpCode);
        }
    }

    /**
     * @param string $exchangeName
     */
    private function removeExchange($exchangeName)
    {
        $dsn = Dsn::parseFirst(getenv('RABBITMQ_AMQP_DSN'));

        $url = sprintf(
            'http://%s:15672/api/exchanges/%s/%s',
            $dsn->getHost(),
            urlencode(ltrim($dsn->getPath(), '/')),
            $exchangeName
        );

        $ch = curl_init();
        curl_setopt($ch, \CURLOPT_URL, $url);
        curl_setopt($ch, \CURLOPT_CUSTOMREQUEST, 'DELETE');
        curl_setopt($ch, \CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, \CURLOPT_HTTPAUTH, \CURLAUTH_BASIC);
        curl_setopt($ch, \CURLOPT_USERPWD, $dsn->getUser().':'.$dsn->getPassword());
        curl_setopt($ch, \CURLOPT_HTTPHEADER, [
            'Content-Type' => 'application/json',
        ]);
        curl_exec($ch);

        $httpCode = curl_getinfo($ch, \CURLINFO_HTTP_CODE);

        curl_close($ch);

        if (false == in_array($httpCode, [204, 404], true)) {
            throw new \LogicException('Failed to remove queue. The response status is '.$httpCode);
        }
    }
}