Dekalee\RedisSwarrot\MessagePublisher\RedisMessagePublisher

Complexity

Total Complexity

3

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

3 Methods

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

<?php

namespace Dekalee\RedisSwarrot\MessagePublisher;

use Swarrot\Broker\Message;
use Swarrot\Broker\MessagePublisher\MessagePublisherInterface;

/**
 * Class RedisMessagePublisher
 */
class RedisMessagePublisher implements MessagePublisherInterface
{
    private $channel;
    private $exchange;

    /**
     * @param \Redis $channel
     * @param string $exchange
     */
    public function __construct(\Redis $channel, $exchange)
    {
        $this->channel = $channel;
        $this->exchange = $exchange;
    }

    /**
     * publish.
     *
     * @param Message $message The message to publish
     * @param string  $key     A routing key to use
     */
    public function publish(Message $message, $key = null)
    {
        $this->channel->lPush($key, $message->getBody());
    }

    /**
     * getExchangeName.
     *
     * Return the name of the exchange where the message will be published
     *
     * @return string
     */
    public function getExchangeName()
    {
        return $this->exchange;
    }
}