Rabbitmq service

Rabbitmq.php

<?php


namespace App\Services;


use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

class Rabbitmq
{
    private $channel, $connection, $queueName = null;

    public function __construct($queueName)
    {
        $this->queueName = $queueName;
        $this->connection = new AMQPStreamConnection(env('QUEUE_HOST'), env('QUEUE_PORT'), env('QUEUE_USER'), env('QUEUE_PASS'));
        $this->channel = $this->connection->channel();
        $this->channel->queue_declare($queueName, false, true, false, false);
    }

    public function sendMessage($message = null)
    {
        $msg = new AMQPMessage($message);
        $this->channel->basic_publish($msg, '', $this->queueName);
    }

    public function consume(callable $callback)
    {
        $this->channel->basic_consume($this->queueName, '', false, true, false, false, $callback);

        while ($this->channel->is_consuming()) {
            $this->channel->wait();
        }
    }
}