Swarrot\Broker\MessageProvider\SimpleStompMessageProvider

Complexity

Total Complexity

7

Size/Duplication

Total Lines	88
Duplicated Lines	25 %

Coupling/Cohesion

Components	2
Dependencies	7

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	14	14	1
A	get()	8	8	2
A	ack()	0	4	1
A	nack()	0	16	2
A	getQueueName()	0	4	1

<?php

namespace Swarrot\Broker\MessageProvider;

use Stomp\Client;
use Stomp\Exception\StompException;
use Stomp\SimpleStomp;
use Stomp\Transport\Message as StompMessage;
use Swarrot\Broker\Message;

class SimpleStompMessageProvider implements MessageProviderInterface
{
    /**
     * @var Client
     */
    private $client;

    /**
     * @var SimpleStomp
     */
    private $stomp;

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

    /**
     * @param Client $client
     * @param string $destination
     * @param null   $subscriptionId
     * @param string $ack
     * @param null   $selector
     * @param array  $header
     */
    public function __construct(

This method seems to be duplicated in your project.

        Client $client,
        $destination,
        $subscriptionId = null,
        $ack = 'client',
        $selector = null,
        array $header = []
    ) {
        $this->client = $client;
        $this->destination = $destination;

        $this->stomp = new SimpleStomp($client);
        $this->stomp->subscribe($destination, $subscriptionId, $ack, $selector, $header);
    }

    public function get()

This method seems to be duplicated in your project.

    {
        if ($frame = $this->stomp->read()) {
            return new Message($frame->getBody(), $frame->getHeaders());
        }

        return null;
    }

    /**
     * @param Message $message
     */
    public function ack(Message $message)
    {
        $this->stomp->ack(new StompMessage($message->getBody(), $message->getProperties()));
    }

    /**
     * @param Message $message
     * @param bool    $requeue
     *
     * @throws StompException
     */
    public function nack(Message $message, $requeue = false)
    {
        $protocol = $this->client->getProtocol();
        if (null === $protocol) {
            throw new StompException('Stomp protocol is require to NACK Frames.');
        }

        $this->client->sendFrame(
            $protocol->getNackFrame(
                new StompMessage($message->getBody(), $message->getProperties()),
                null,
                $requeue
            ),
            false
        );
    }

    /**
     * @return string
     */
    public function getQueueName()
    {
        return $this->destination;
    }
}