BinaryCube\CarrotMQ\Event\Consumer\AfterMessageReceived

Complexity

Total Complexity

10

Size/Duplication

Total Lines	135
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	isExecutionInterrupted()	0	3	1
A	result()	0	3	1
A	exitStatus()	0	3	1
A	receivedAt()	0	3	1
A	queue()	0	3	1
A	context()	0	3	1
A	interruptExecution()	0	4	1
A	message()	0	3	1
A	name()	0	3	1
A	__construct()	0	13	1

<?php

declare(strict_types=1);

namespace BinaryCube\CarrotMQ\Event\Consumer;

use Interop\Queue\Context;
use Interop\Queue\Message;
use BinaryCube\CarrotMQ\Event\Event;
use BinaryCube\CarrotMQ\Entity\Queue;

/**
 * Class AfterMessageReceived
 */
class AfterMessageReceived extends Event
{

    /**
     * @var Queue
     */
    private $queue;

    /**
     * @var Context
     */
    private $context;

    /**
     * @var Message
     */
    private $message;

    /**
     * @var float
     */
    private $receivedAt;

    /**
     * @var string
     */
    private $result;

    /**
     * @var boolean
     */
    private $executionInterrupted;

    /**
     * @var integer
     */
    private $exitStatus;

    /**
     * @return string
     */
    public static function name(): string
    {
        return 'consumer.event.after.message.received';
    }

    /**
     * Constructor.
     *
     * @param Queue   $queue
     * @param Context $context
     * @param Message $message
     * @param float   $receivedAt
     * @param string  $result
     */
    public function __construct(
        Queue $queue,
        Context $context,
        Message $message,
        float $receivedAt,
        string $result
    ) {
        $this->queue                = $queue;
        $this->context              = $context;
        $this->message              = $message;
        $this->receivedAt           = $receivedAt;
        $this->result               = $result;
        $this->executionInterrupted = false;
    }

    /**
     * @return Queue
     */
    public function queue(): Queue
    {
        return $this->queue;
    }

    /**
     * @return Context
     */
    public function context(): Context
    {
        return $this->context;
    }

    /**
     * @return Message
     */
    public function message(): Message
    {
        return $this->message;
    }

    /**
     * @return float
     */
    public function receivedAt(): float
    {
        return $this->receivedAt;
    }

    /**
     * @return string
     */
    public function result(): string
    {
        return $this->result;
    }

    /**
     * @return int|null
     */
    public function exitStatus(): ?int
    {
        return $this->exitStatus;
    }

    /**
     * @return bool
     */
    public function isExecutionInterrupted(): bool
    {
        return $this->executionInterrupted;
    }

    /**
     * @param int|null $exitStatus
     *
     * @return void;
     */
    public function interruptExecution(?int $exitStatus = null): void
    {
        $this->exitStatus           = $exitStatus;
        $this->executionInterrupted = true;
    }

}