MuCTS\Laravel\AMQP\Message

Complexity

Total Complexity

6

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Importance

Changes	2
Bugs	1	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	ack()	0	3	1
A	__construct()	0	3	1
A	cancel()	0	3	1
A	getMessage()	0	2	1
A	__call()	0	3	1
A	__get()	0	3	1

<?php
/**
 * This file is part of the mucts.com.
 *
 * This source file is subject to the MIT license that is bundled
 * with this source code in the file LICENSE.
 *
 * @version 1.0
 * @author herry<yuandeng@aliyun.com>
 * @copyright © 2020  MuCTS.com All Rights Reserved.
 */

namespace MuCTS\Laravel\AMQP;


use PhpAmqpLib\Message\AMQPMessage;

/**
 * Class Message
 *
 * @mixin AMQPMessage
 * @package MuCTS\Laravel\AMQP
 */
class Message
{
    private AMQPMessage $message;

    public function __construct(AMQPMessage $message)
    {
        $this->message = $message;
    }

    /**
     * Send a message ack the consumer.
     */
    public function ack()
    {
        $this->message->delivery_info['channel']->basic_ack($this->message->delivery_info['delivery_tag']);
    }

    /**
     * Send a message cancel the consumer.
     */
    public function cancel()
    {
        $this->message->delivery_info['channel']->basic_cancel($this->message->delivery_info['consumer_tag']);
    }

    /**
     * Get AMQPMessage
     *
     * @return AMQPMessage
     */
    public function getMessage(){
        return $this->message;
    }

    /**
     * Dynamically pass methods to the message.
     *
     * @param string $method
     * @param array $arguments
     * @return mixed
     */
    public function __call($method, $arguments)
    {
        return $this->message->{$method}(...$arguments);
    }

    /**
     * Dynamically pass value to the message.
     *
     * @param string $name
     * @return mixed
     */
    public function __get($name)
    {
        return $this->message->{$name};
    }
}