Daikon\RabbitMq3\Transport\RabbitMq3Transport

Complexity

Total Complexity

3

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	send()	0	16	1
A	getKey()	0	3	1
A	__construct()	0	4	1

<?php

namespace Daikon\RabbitMq3\Transport;

use Assert\Assertion;
use Daikon\MessageBus\Channel\Subscription\Transport\TransportInterface;
use Daikon\MessageBus\EnvelopeInterface;
use Daikon\MessageBus\MessageBusInterface;
use Daikon\RabbitMq3\Connector\RabbitMq3Connector;
use PhpAmqpLib\Message\AMQPMessage;

final class RabbitMq3Transport implements TransportInterface
{
    private $key;

    private $connector;

    public function __construct(string $key, RabbitMq3Connector $connector)
    {
        $this->key = $key;
        $this->connector = $connector;
    }

    public function send(EnvelopeInterface $envelope, MessageBusInterface $messageBus): bool
    {
        $metadata = $envelope->getMetadata();
        $exchange = $metadata->get('_exchange');
        $routingKey = $metadata->get('_routing_key', $metadata->get('_aggregate_alias', ''));

        Assertion::notBlank($exchange);
        Assertion::string($routingKey);

        $payload = json_encode($envelope->toArray(), true);

true of type true is incompatible with the type integer expected by parameter $options of json_encode().

        $message = new AMQPMessage($payload, ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);

        $channel = $this->connector->getConnection()->channel();
        $channel->basic_publish($message, $exchange, $routingKey);

        return true;
    }

    public function getKey(): string
    {
        return $this->key;
    }
}