Burrow\Publisher\SerializingPublisher

Complexity

Total Complexity

2

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

2 Methods

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

<?php

namespace Burrow\Publisher;

use Burrow\QueuePublisher;
use Burrow\Serializer;

class SerializingPublisher implements QueuePublisher
{
    /** @var QueuePublisher */
    private $publisher;

    /** @var Serializer */
    private $serializer;

    /**
     * SerializingPublisher constructor.
     *
     * @param QueuePublisher $publisher
     * @param Serializer     $serializer
     */
    public function __construct(
        QueuePublisher $publisher,
        Serializer $serializer
    ) {
        $this->publisher = $publisher;
        $this->serializer = $serializer;
    }

    /**
     * Publish a message on the queue
     *
     * @param mixed    $data
     * @param string   $routingKey
     * @param string[] $headers
     *
     * @return mixed
     */
    public function publish($data, $routingKey = '', array $headers = [])
    {
        $returnValue = $this->publisher->publish(
            $this->serializer->serialize($data),
            $routingKey,
            $headers
        );

        return $this->serializer->deserialize($returnValue);
    }
}