Burrow\Publisher\SyncPublisher

Complexity

Total Complexity

3

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
B	publish()	0	25	2

<?php

namespace Burrow\Publisher;

use Burrow\Driver;
use Burrow\Message;
use Burrow\QueueHandler;
use Burrow\QueuePublisher;

class SyncPublisher implements QueuePublisher
{
    /** @var Driver */
    private $driver;

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

    /** @var int */
    private $timeout;

    /**
     * Constructor
     *
     * @param Driver $driver
     * @param string $exchangeName
     * @param int    $timeout
     */
    public function __construct(Driver $driver, $exchangeName, $timeout = 10)
    {
        $this->driver = $driver;
        $this->exchangeName = $exchangeName;
        $this->timeout = $timeout;
    }

    /**
     * Publish a message on the queue
     *
     * @param mixed    $data
     * @param string   $routingKey
     * @param string[] $headers
     *
     * @return mixed
     */
    public function publish($data, $routingKey = '', array $headers = [])
    {
        $response = null;
        $correlationId = uniqid();
        $replyTo = $this->driver->declareSimpleQueue('', Driver::QUEUE_EXCLUSIVE);

        $this->driver->publish(
            $this->exchangeName,
            new Message($data, $routingKey, $headers, $correlationId, $replyTo)

$headers is of type array<integer,string>, but the function expects a array<integer,object<string>>.

        );

        $this->driver->consume(
            $replyTo,
            function (Message $message) use ($replyTo, $correlationId, &$response) {
                if ($message->getCorrelationId() == $correlationId) {
                    $response = $message->getBody();
                    return QueueHandler::STOP_CONSUMING;
                }
                return QueueHandler::CONTINUE_CONSUMING;
            },
            $this->timeout
        );

        return $response;
    }
}