Innmind\AMQPBundle\Producer\Producer

Complexity

Total Complexity

2

Size/Duplication

Total Lines	28
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	__invoke()	0	14	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQPBundle\Producer;

use Innmind\AMQPBundle\Producer as ProducerInterface;
use Innmind\AMQP\{
    Client,
    Model\Basic\Publish,
    Model\Basic\Message
};

final class Producer implements ProducerInterface
{
    private $client;
    private $exchange;

    public function __construct(
        Client $client,
        string $exchange
    ) {
        $this->client = $client;
        $this->exchange = $exchange;
    }

    public function __invoke(Message $message, string $routingKey = null): ProducerInterface
    {
        $this
            ->client
            ->channel()
            ->basic()
            ->publish(
                (new Publish($message))
                    ->to($this->exchange)
                    ->withRoutingKey($routingKey ?? '')
            );

        return $this;
    }
}