Aimeos\MW\MQueue\Stomp

Complexity

Total Complexity

10

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
C	getQueue()	0	36	8
A	connect()	0	8	2

<?php

namespace Aimeos\MW\MQueue;


class Stomp extends Base implements Iface
{
	private $queues = array();


	/**
	 * Returns the queue for the given name
	 *
	 * @param string $name Queue name
	 * @return \Aimeos\MW\MQueue\Queue\Iface Message queue
	 */
	public function getQueue( $name )
	{
		if( !isset( $this->queues[$name] ) )
		{
			$uri = $this->getConfig( 'uri', 'tcp://localhost:61613' );
			$user = $this->getConfig( 'username', null );
			$pass = $this->getConfig( 'password', null );

			if( is_array( $uri ) )
			{
				foreach( $uri as $idx => $entry )
				{
					$iuser = ( is_array( $user) ? $user[$idx] : $user );
					$ipass = ( is_array( $pass) ? $pass[$idx] : $pass );

					$result = $this->connect( $entry, $iuser, $ipass );

					if( $result instanceof \Stomp ) {

The class Stomp does not exist. Did you forget a USE statement, or did you not list all dependencies?

						break;
					}
				}
			}
			else
			{
				$result = $this->connect( $uri, $user, $pass );
			}

			if( $result instanceof \StompException ) {

The variable $result does not seem to be defined for all execution paths leading up to this point.

The class StompException does not exist. Did you forget a USE statement, or did you not list all dependencies?

				throw new \Aimeos\MW\MQueue\Exception( $result->getMessage() );
			}

			$this->queues[$name] = new \Aimeos\MW\MQueue\Queue\Stomp( $result, $name );
		}

		return $this->queues[$name];
	}


	/**
	 * Opens a connection to the message queue server
	 *
	 * @param string $uri Connection URI
	 * @param string $user User name for authentication
	 * @param string $pass Password for authentication
	 * @return \Stomp|\StompException
	 */
	protected function connect( $uri, $user, $pass )
	{
		try {
			return new \Stomp( $uri, $user, $pass );
		} catch( \StompException $e ) {

The class StompException does not exist. Did you forget a USE statement, or did you not list all dependencies?

			return $e;
		}
	}
}