Gears\CQRS\Async\QueueInterop\QueueInteropCommandQueue

Complexity

Total Complexity

5

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	send()	0	10	2
A	getMessage()	0	4	1
A	getMessageProducer()	0	4	1

<?php

/*
 * cqrs-async-queue-interop (https://github.com/phpgears/cqrs-async-queue-interop).
 * Queue-interop async decorator for CQRS command bus.
 *
 * @license MIT
 * @link https://github.com/phpgears/cqrs-async-queue-interop
 * @author Julián Gutiérrez <juliangut@gmail.com>
 */

declare(strict_types=1);

namespace Gears\CQRS\Async\QueueInterop;

use Gears\CQRS\Async\AbstractCommandQueue;
use Gears\CQRS\Async\Exception\CommandQueueException;
use Gears\CQRS\Async\Serializer\CommandSerializer;
use Gears\CQRS\Command;
use Interop\Queue\PsrContext;
use Interop\Queue\PsrDestination;
use Interop\Queue\PsrMessage;
use Interop\Queue\PsrProducer;

class QueueInteropCommandQueue extends AbstractCommandQueue
{
    /**
     * Queue context.
     *
     * @var PsrContext
     */
    private $context;

    /**
     * @var PsrDestination
     */
    private $destination;

    /**
     * EnqueueCommandBus constructor.
     *
     * @param CommandSerializer $serializer
     * @param PsrContext        $context
     * @param PsrDestination    $destination
     */
    public function __construct(CommandSerializer $serializer, PsrContext $context, PsrDestination $destination)
    {
        parent::__construct($serializer);

        $this->context = $context;
        $this->destination = $destination;
    }

    /**
     * {@inheritdoc}
     */
    final public function send(Command $command): void
    {
        // @codeCoverageIgnoreStart
        try {
            $this->getMessageProducer()->send($this->destination, $this->getMessage($command));
        } catch (\Exception $exception) {
            throw new CommandQueueException('Failure enqueueing command', 0, $exception);
        }
        // @codeCoverageIgnoreEnd
    }

    /**
     * Get message from command.
     *
     * @param Command $command
     *
     * @return PsrMessage
     */
    protected function getMessage(Command $command): PsrMessage
    {
        return $this->context->createMessage($this->getSerializedCommand($command));
    }

    /**
     * Get message producer.
     *
     * @return PsrProducer
     */
    protected function getMessageProducer(): PsrProducer
    {
        return $this->context->createProducer();
    }
}