Kunnu\RabbitMQ\RabbitMQMessageConsumer

Complexity

Total Complexity

7

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
A	setConfig()	0	5	1
A	getExchange()	0	3	1
A	__construct()	0	3	1
A	getConfig()	0	3	1
A	setQueue()	0	5	1
A	getQueue()	0	3	1
A	setExchange()	0	5	1

<?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);

        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;
    }
}