Enqueue\SimpleBus\SimpleBusPublisher

Complexity

Total Complexity

2

Size/Duplication

Total Lines	20
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	publish()	0	7	1
A	__construct()	0	5	1

<?php

declare(strict_types=1);

namespace Enqueue\SimpleBus;

use Interop\Queue\Context;
use SimpleBus\Asynchronous\Publisher\Publisher;
use SimpleBus\Asynchronous\Routing\RoutingKeyResolver;
use SimpleBus\Serialization\Envelope\Serializer\MessageInEnvelopeSerializer;

final class SimpleBusPublisher implements Publisher
{
    private $serializer;
    private $queueResolver;
    private $context;

    public function __construct(MessageInEnvelopeSerializer $serializer, RoutingKeyResolver $queueResolver, Context $context)
    {
        $this->serializer = $serializer;
        $this->queueResolver = $queueResolver;
        $this->context = $context;
    }

    public function publish($message): void
    {
        $queue = $this->context->createQueue($this->queueResolver->resolveRoutingKeyFor($message));

        $message = $this->context->createMessage($this->serializer->wrapAndSerialize($message));

        $this->context->createProducer()->send($queue, $message);
    }
}