Kunnu\RabbitMQ\RabbitMQDelivery

Complexity

Total Complexity

8

Size/Duplication

Total Lines	90
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	reject()	0	19	2
A	setConfig()	0	5	1
A	acknowledge()	0	24	3
A	__construct()	0	3	1
A	getConfig()	0	3	1

<?php

namespace Kunnu\RabbitMQ;

use Illuminate\Support\Collection;
use PhpAmqpLib\Channel\AMQPChannel;

class RabbitMQDelivery
{
    protected Collection $config;

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

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

    /**
     * @param array $config
     *
     * @return \Anik\Amqp\Delivery

The type Anik\Amqp\Delivery was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    public function setConfig(array $config): self
    {
        $this->config = new Collection($config);

        return $this;
    }

    /**
     * Acknowledge a message.
     *
     * @throws RabbitMQException
     * @return bool
     *
     */
    public function acknowledge(): bool
    {
        $config = $this->getConfig();
        $info = $config->get('delivery_info', []);
        /**
         * @var AMQPChannel
         */
        $channel = $info['channel'] ?? null;

        if (!$channel) {
            throw new RabbitMQException('Delivery info or channel is not set');
        }

        $channel->basic_ack(
            $info['delivery_tag'] ?? null
        );

        if ($config->get('body') === 'quit') {
            $channel->basic_cancel(
                $info['consumer_tag'] ?? null
            );
        }

        return true;
    }

    /**
     * Rejects message w/ requeue.
     *
     * @param bool $requeue
     *
     * @throws RabbitMQException
     * @return bool
     *
     */
    public function reject($requeue = false): bool
    {
        $config = $this->getConfig();
        $info = $config->get('delivery_info');
        /**
         * @var AMQPChannel
         */
        $channel = $info['channel'] ?? null;

        if (!$channel) {
            throw new RabbitMQException('Delivery info or channel is not set');
        }

        $channel->basic_reject(
            $info['delivery_tag'] ?? null,
            $requeue
        );

        return true;
    }
}