Amqp.php

Go to the documentation of this file.

<?php
declare(strict_types=1);

namespace Magento\TestFramework\Helper;

class Amqp
{
    private $curl;

    private $host = 'http://localhost:15672/api/';

    public function __construct()
    {
        $this->curl = new Curl();
        $this->curl->setCredentials('guest', 'guest');
        $this->curl->addHeader('content-type', 'application/json');
    }

    public function getExchanges()
    {
        $this->curl->get($this->host . 'exchanges');
        $data = $this->curl->getBody();
        $data = json_decode($data, true);
        $output = [];
        foreach ($data as $value) {
            $output[$value['name']] = $value;
        }
        return $output;
    }

    public function getExchangeBindings($name)
    {
        $this->curl->get($this->host . 'exchanges/%2f/' . $name . '/bindings/source');
        $data = $this->curl->getBody();
        return json_decode($data, true);
    }

    public function getConnections()
    {
        $this->curl->get($this->host . 'connections');
        $data = $this->curl->getBody();
        $data = json_decode($data, true);
        $output = [];
        foreach ($data as $value) {
            $output[$value['name']] = $value;
        }
        return $output;
    }

    public function clearQueue(string $name, int $numMessages = 50)
    {
        $body = [
            "count" => $numMessages,
            "ackmode" => "ack_requeue_false",
            "encoding" => "auto",
            "truncate" => 50000
        ];
        $this->curl->post($this->host . 'queue/%2f/' . $name . '/get', json_encode($body));
        return $this->curl->getBody();
    }

    public function deleteConnection($name)
    {
        $this->curl->delete($this->host . 'conections/' . urlencode($name));
        $data = $this->curl->getBody();
        return $data;
    }
}