kunalvarma05 / laravel-rabbitmq

src/RabbitMQMessageConsumer.php

<?php

namespace Kunnu\RabbitMQ;

use Illuminate\Support\Collection;

abstract class RabbitMQMessageConsumer
{
    protected Collection $config;

    protected ?RabbitMQExchange $exchange = null;

    protected ?RabbitMQQueue $queue = null;

    public function __construct(array $config = [])
    {
        $this->setConfig($config);
    }

    /**
     * Handle an incoming message.
     *
     * @param  RabbitMQIncomingMessage  $message
     * @return void
     */
    abstract public function handle(RabbitMQIncomingMessage $message): void;

    /**
     * Get config.
     *
     * @return Collection
     */
    public function getConfig(): Collection
    {
        return $this->config;
    }

    /**
     * Set configuration.
     *
     * @param  array  $config
     * @return self
     */
    public function setConfig(array $config): self
    {
        $this->config = new Collection($config);

$config of type array is incompatible with the type Illuminate\Contracts\Support\Arrayable expected by parameter $items of Illuminate\Support\Collection::__construct().

        return $this;
    }

    /**
     * @return null|\Kunnu\RabbitMQ\RabbitMQExchange|null
     */
    public function getExchange(): ?RabbitMQExchange
    {
        return $this->exchange;
    }

    /**
     * @param  \Kunnu\RabbitMQ\RabbitMQExchange|null  $exchange
     * @return self
     */
    public function setExchange(?RabbitMQExchange $exchange): self
    {
        $this->exchange = $exchange;

        return $this;
    }

    /**
     * @return null|\Kunnu\RabbitMQ\RabbitMQQueue|null
     */
    public function getQueue(): ?RabbitMQQueue
    {
        return $this->queue;
    }

    /**
     * @param  \Kunnu\RabbitMQ\RabbitMQQueue|null  $queue
     * @return self
     */
    public function setQueue(?RabbitMQQueue $queue): self
    {
        $this->queue = $queue;

        return $this;
    }
}