Kaliop\Queueing\Plugins\StompBundle\Adapter\Stomp\Stomp

Complexity

Total Complexity

15

Size/Duplication

Total Lines	112
Duplicated Lines	6.25 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	2
A	__destruct()	0	6	2
A	setCredentials()	0	7	1
A	setDebug()	0	6	1
A	setStompQueueName()	0	6	1
A	getStompQueueName()	0	4	1
A	getFullQueueName()	7	17	4
A	connect()	0	8	3

<?php

namespace Kaliop\Queueing\Plugins\StompBundle\Adapter\Stomp;

/// @todo find a better name for this class
class Stomp
{
    protected $client;
    protected $username;
    protected $password;
    protected $stompQueueName;
    protected $connected = false;

    /**
     * @param array $connectionConfig keys:
     *                                - connect_string
     *                                - credentials (optional, must be an array with 'user' and 'password'
     */
    public function __construct(array $connectionConfig)
    {
        $connectString = $connectionConfig['connect_string'];
        $this->client = new Client($connectString);
        if (isset($connectionConfig['credentials'])) {
            $this->setCredentials($connectionConfig['credentials']['user'], $connectionConfig['credentials']['password']);
        }
    }

    public function __destruct()
    {
        if ($this->connected) {
            $this->client->disconnect();
        }
    }

    public function setCredentials($username, $password)
    {
        $this->username = $username;
        $this->password = $password;

        return $this;
    }

    /**
     * @param bool
     * @return Consumer
     */
    public function setDebug($debug)
    {
        $this->client->debug = $debug;

        return $this;
    }

    /**
     * @param string $queueName NB: queue name as used by Stomp, including the prefix used by the broker to specify the
     *                          message delivery pattern
     * @return Producer
     */
    public function setStompQueueName($queueName)
    {
        $this->stompQueueName = $queueName;

        return $this;
    }

    /**
     * @return string the queue name as used by Stomp
     */
    public function getStompQueueName()
    {
        return $this->setompQueueName;

The property setompQueueName does not seem to exist. Did you mean stompQueueName?

    }

    /**
     * Returns the full queue name to be used in stomp messages.
     * - Apache Apollo supports using routing keys at end of queue name @see https://activemq.apache.org/apollo/documentation/stomp-manual.html#Destination_Wildcards
     * - ActiveMQ: @see http://activemq.apache.org/wildcards.html
     * - RabbitMQ: @see https://www.rabbitmq.com/stomp.html
     * - Artemis: @see https://activemq.apache.org/components/artemis/documentation/latest/stomp.html
     *
     * @param string $routingKey assumes the amqp pattern: *=1word, #=0-or-more
     * @return string;

The doc-type string; could not be parsed: Expected "|" or "end of type", but got ";" at position 6. (view supported doc-types)

     */
    protected function getFullQueueName($routingKey = '')
    {
        $queueName = $this->stompQueueName;
        if ($routingKey != '') {
            switch($this->client->brokerVendor) {
                case 'Apollo':

This code seems to be duplicated across your project.

                    $routingKey = str_replace('#', '**', $routingKey);
                    $queueName = rtrim($queueName, '.') . '.' . ltrim($routingKey, '.');
                    break;
                case 'AMQ':
                default:

This code seems to be duplicated across your project.

                    $routingKey = str_replace('#', '>', $routingKey);
                    $queueName = rtrim($queueName, '.') . '.' . ltrim($routingKey, '.');
            }
        }
        return $queueName;
    }

    /**
     * Connects to the Stomp server. Attempts the connection only once by default, regardless of results
     *
     * @param bool $onlyOnce
     * @throws \FuseSource\Stomp\Exception\StompException
     */
    protected function connect($onlyOnce = true)
    {
        if ($onlyOnce && $this->connected) {
            return;
        }
        $this->client->connect($this->username, $this->password);
        $this->connected = true;
    }

}