aimeos / ai-mqueue

lib/custom/tests/MW/MQueue/Message/AMQPTest.php

Spacing +7 added lines, -7 removed lines

@@ -10,29 +10,29 @@
 
 	protected function setUp()
 	{
-		if( class_exists( '\PhpAmqpLib\Message\AMQPMessage' ) === false ) {
-			$this->markTestSkipped( 'Please install the "php-amqplib" library via composer first' );
+		if (class_exists('\PhpAmqpLib\Message\AMQPMessage') === false) {
+			$this->markTestSkipped('Please install the "php-amqplib" library via composer first');
 		}
 
-		$msg = new \PhpAmqpLib\Message\AMQPMessage( 'test' );
-		$this->object = new \Aimeos\MW\MQueue\Message\AMQP( $msg );
+		$msg = new \PhpAmqpLib\Message\AMQPMessage('test');
+		$this->object = new \Aimeos\MW\MQueue\Message\AMQP($msg);
 	}
 
 
 	protected function tearDown()
 	{
-		unset( $this->object );
+		unset($this->object);
 	}
 
 
 	public function testGetBody()
 	{
-		$this->assertEquals( 'test', $this->object->getBody() );
+		$this->assertEquals('test', $this->object->getBody());
 	}
 
 
 	public function testGetObject()
 	{
-		$this->assertInstanceOf( '\PhpAmqpLib\Message\AMQPMessage', $this->object->getObject() );
+		$this->assertInstanceOf('\PhpAmqpLib\Message\AMQPMessage', $this->object->getObject());
 	}
 }

lib/custom/tests/MW/MQueue/AMQPTest.php

Spacing +25 added lines, -25 removed lines

@@ -7,8 +7,8 @@ 
 {
 	protected function setUp()
 	{
-		if( class_exists( '\PhpAmqpLib\Connection\AMQPStreamConnection' ) === false ) {
-			$this->markTestSkipped( 'Please install the "php-amqplib" library via composer first' );
+		if (class_exists('\PhpAmqpLib\Connection\AMQPStreamConnection') === false) {
+			$this->markTestSkipped('Please install the "php-amqplib" library via composer first');
 		}
 	}
 
@@ -17,65 +17,65 @@ 
 	{
 		try
 		{
-			$mqueue = new \Aimeos\MW\MQueue\AMQP( array( 'host' => 'localhost' ) );
-			$queue = $mqueue->getQueue( 'aimeos_unittest' );
+			$mqueue = new \Aimeos\MW\MQueue\AMQP(array('host' => 'localhost'));
+			$queue = $mqueue->getQueue('aimeos_unittest');
 		}
-		catch( \Aimeos\MW\MQueue\Exception $e )
+		catch (\Aimeos\MW\MQueue\Exception $e)
 		{
-			$this->markTestSkipped( 'No AMQP compliant server available at "localhost"' );
+			$this->markTestSkipped('No AMQP compliant server available at "localhost"');
 		}
 
-		$queue->add( 'testmsg' );
+		$queue->add('testmsg');
 		$msg = $queue->get();
-		$queue->del( $msg );
+		$queue->del($msg);
 
-		$this->assertNull( $queue->get() );
+		$this->assertNull($queue->get());
 	}
 
 
 	public function testSingleConnection()
 	{
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		new \Aimeos\MW\MQueue\AMQP( array( 'host' => '192.168.255.255', 'connection_timeout' => 0.1 ) );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		new \Aimeos\MW\MQueue\AMQP(array('host' => '192.168.255.255', 'connection_timeout' => 0.1));
 	}
 
 
 	public function testMultiConnection()
 	{
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		new \Aimeos\MW\MQueue\AMQP( array( 'host' => array( '192.168.254.255', '192.168.255.255' ), 'connection_timeout' => 0.1 ) );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		new \Aimeos\MW\MQueue\AMQP(array('host' => array('192.168.254.255', '192.168.255.255'), 'connection_timeout' => 0.1));
 	}
 
 
 	public function testGetQueue()
 	{
-		$channel = $this->getMockBuilder( 'PhpAmqpLib\Channel\AMQPChannel' )
+		$channel = $this->getMockBuilder('PhpAmqpLib\Channel\AMQPChannel')
 			->disableOriginalConstructor()
 			->getMock();
 
-		$object = $this->getMockBuilder( '\Aimeos\MW\MQueue\AMQP' )
-			->setMethods( array( 'getChannel', '__destruct' ) )
+		$object = $this->getMockBuilder('\Aimeos\MW\MQueue\AMQP')
+			->setMethods(array('getChannel', '__destruct'))
 			->disableOriginalConstructor()
 			->getMock();
 
-		$object->expects( $this->once() )->method( 'getChannel' )
-			->will( $this->returnValue( $channel ) );
+		$object->expects($this->once())->method('getChannel')
+			->will($this->returnValue($channel));
 
-		$this->assertInstanceOf( '\Aimeos\MW\MQueue\Queue\Iface', $object->getQueue( 'test' ) );
+		$this->assertInstanceOf('\Aimeos\MW\MQueue\Queue\Iface', $object->getQueue('test'));
 	}
 
 
 	public function testGetQueueException()
 	{
-		$object = $this->getMockBuilder( '\Aimeos\MW\MQueue\AMQP' )
-			->setMethods( array( 'getChannel', '__destruct' ) )
+		$object = $this->getMockBuilder('\Aimeos\MW\MQueue\AMQP')
+			->setMethods(array('getChannel', '__destruct'))
 			->disableOriginalConstructor()
 			->getMock();
 
-		$object->expects( $this->once() )->method( 'getChannel' )
-			->will( $this->throwException( new \Exception() ) );
+		$object->expects($this->once())->method('getChannel')
+			->will($this->throwException(new \Exception()));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		$object->getQueue( 'test' );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		$object->getQueue('test');
 	}
 }

Braces +1 added lines, -2 removed lines

@@ -19,8 +19,7 @@
 		{
 			$mqueue = new \Aimeos\MW\MQueue\AMQP( array( 'host' => 'localhost' ) );
 			$queue = $mqueue->getQueue( 'aimeos_unittest' );
-		}
-		catch( \Aimeos\MW\MQueue\Exception $e )
+		} catch( \Aimeos\MW\MQueue\Exception $e )
 		{
 			$this->markTestSkipped( 'No AMQP compliant server available at "localhost"' );
 		}

lib/custom/src/MW/MQueue/Stomp.php

Spacing +18 added lines, -18 removed lines

@@ -14,38 +14,38 @@ 
 	 * @param string $name Queue name
 	 * @return \Aimeos\MW\MQueue\Queue\Iface Message queue
 	 */
-	public function getQueue( $name )
+	public function getQueue($name)
 	{
-		if( !isset( $this->queues[$name] ) )
+		if (!isset($this->queues[$name]))
 		{
-			$uri = $this->getConfig( 'uri', 'tcp://localhost:61613' );
-			$user = $this->getConfig( 'username', null );
-			$pass = $this->getConfig( 'password', null );
+			$uri = $this->getConfig('uri', 'tcp://localhost:61613');
+			$user = $this->getConfig('username', null);
+			$pass = $this->getConfig('password', null);
 
-			if( is_array( $uri ) )
+			if (is_array($uri))
 			{
-				foreach( $uri as $idx => $entry )
+				foreach ($uri as $idx => $entry)
 				{
-					$iuser = ( is_array( $user) ? $user[$idx] : $user );
-					$ipass = ( is_array( $pass) ? $pass[$idx] : $pass );
+					$iuser = (is_array($user) ? $user[$idx] : $user);
+					$ipass = (is_array($pass) ? $pass[$idx] : $pass);
 
-					$result = $this->connect( $entry, $iuser, $ipass );
+					$result = $this->connect($entry, $iuser, $ipass);
 
-					if( $result instanceof \Stomp ) {
+					if ($result instanceof \Stomp) {
 						break;
 					}
 				}
 			}
 			else
 			{
-				$result = $this->connect( $uri, $user, $pass );
+				$result = $this->connect($uri, $user, $pass);
 			}
 
-			if( $result instanceof \StompException ) {
-				throw new \Aimeos\MW\MQueue\Exception( $result->getMessage() );
+			if ($result instanceof \StompException) {
+				throw new \Aimeos\MW\MQueue\Exception($result->getMessage());
 			}
 
-			$this->queues[$name] = new \Aimeos\MW\MQueue\Queue\Stomp( $result, $name );
+			$this->queues[$name] = new \Aimeos\MW\MQueue\Queue\Stomp($result, $name);
 		}
 
 		return $this->queues[$name];
@@ -60,11 +60,11 @@ 
 	 * @param string $pass Password for authentication
 	 * @return \Stomp|\StompException
 	 */
-	protected function connect( $uri, $user, $pass )
+	protected function connect($uri, $user, $pass)
 	{
 		try {
-			return new \Stomp( $uri, $user, $pass );
-		} catch( \StompException $e ) {
+			return new \Stomp($uri, $user, $pass);
+		} catch (\StompException $e) {
 			return $e;
 		}
 	}

Braces +1 added lines, -2 removed lines

@@ -35,8 +35,7 @@
 						break;
 					}
 				}
-			}
-			else
+			} else
 			{
 				$result = $this->connect( $uri, $user, $pass );
 			}

lib/custom/src/MW/MQueue/Queue/Beanstalk.php

Spacing +14 added lines, -14 removed lines

@@ -17,12 +17,12 @@ 
 	 * @param string $queue Message queue name
 	 * @throws \Aimeos\MW\MQueue\Exception
 	 */
-	public function __construct( \Pheanstalk\PheanstalkInterface $client, $queue, $timeout = null )
+	public function __construct(\Pheanstalk\PheanstalkInterface $client, $queue, $timeout = null)
 	{
 		try {
-			$client->useTube( $queue )->watch( $queue );
-		} catch( \Exception $e ) {
-			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
+			$client->useTube($queue)->watch($queue);
+		} catch (\Exception $e) {
+			throw new \Aimeos\MW\MQueue\Exception($e->getMessage());
 		}
 
 		$this->client = $client;
@@ -36,12 +36,12 @@ 
 	 *
 	 * @param string $msg Message, e.g. JSON encoded data
 	 */
-	public function add( $msg )
+	public function add($msg)
 	{
 		try {
-			$this->client->put( $msg );
-		} catch( \Exception $e ) {
-			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
+			$this->client->put($msg);
+		} catch (\Exception $e) {
+			throw new \Aimeos\MW\MQueue\Exception($e->getMessage());
 		}
 	}
 
@@ -51,12 +51,12 @@ 
 	 *
 	 * @param \Aimeos\MW\MQueue\Message\Iface $msg Message object
 	 */
-	public function del( \Aimeos\MW\MQueue\Message\Iface $msg )
+	public function del(\Aimeos\MW\MQueue\Message\Iface $msg)
 	{
 		try {
-			$this->client->delete( $msg->getObject() );
-		} catch( \Exception $e ) {
-			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
+			$this->client->delete($msg->getObject());
+		} catch (\Exception $e) {
+			throw new \Aimeos\MW\MQueue\Exception($e->getMessage());
 		}
 	}
 
@@ -68,8 +68,8 @@ 
 	 */
 	public function get()
 	{
-		if( ( $job = $this->client->reserve( $this->timeout ) ) !== false ) {
-			return new \Aimeos\MW\MQueue\Message\Beanstalk( $job );
+		if (($job = $this->client->reserve($this->timeout)) !== false) {
+			return new \Aimeos\MW\MQueue\Message\Beanstalk($job);
 		}
 	}
 }

lib/custom/src/MW/MQueue/Beanstalk.php

Spacing +20 added lines, -20 removed lines

@@ -14,32 +14,32 @@ 
 	 *
 	 * @param array $config Associative list of configuration key/value pairs
 	 */
-	public function __construct( array $config )
+	public function __construct(array $config)
 	{
-		parent::__construct( $config );
+		parent::__construct($config);
 
-		$host = $this->getConfig( 'host', 'localhost' );
-		$port = $this->getConfig( 'port', \Pheanstalk\PheanstalkInterface::DEFAULT_PORT );
+		$host = $this->getConfig('host', 'localhost');
+		$port = $this->getConfig('port', \Pheanstalk\PheanstalkInterface::DEFAULT_PORT);
 
-		if( is_array( $host ) )
+		if (is_array($host))
 		{
-			foreach( $host as $idx => $entry )
+			foreach ($host as $idx => $entry)
 			{
-				$iport = ( is_array( $port) ? $port[$idx] : $port );
-				$this->client = $this->connect( $entry, $iport );
+				$iport = (is_array($port) ? $port[$idx] : $port);
+				$this->client = $this->connect($entry, $iport);
 
-				if( $this->client instanceof \Pheanstalk\PheanstalkInterface ) {
+				if ($this->client instanceof \Pheanstalk\PheanstalkInterface) {
 					break;
 				}
 			}
 		}
 		else
 		{
-			$this->client = $this->connect( $host, $port );
+			$this->client = $this->connect($host, $port);
 		}
 
-		if( $this->client instanceof \Pheanstalk\Exception ) {
-			throw new \Aimeos\MW\MQueue\Exception( $this->client->getMessage() );
+		if ($this->client instanceof \Pheanstalk\Exception) {
+			throw new \Aimeos\MW\MQueue\Exception($this->client->getMessage());
 		}
 	}
 
@@ -50,12 +50,12 @@ 
 	 * @param string $name Queue name
 	 * @return \Aimeos\MW\MQueue\Queue\Iface Message queue
 	 */
-	public function getQueue( $name )
+	public function getQueue($name)
 	{
-		if( !isset( $this->queues[$name] ) )
+		if (!isset($this->queues[$name]))
 		{
-			$timeout = $this->getConfig( 'readtimeout', 30 );
-			$this->queues[$name] = new \Aimeos\MW\MQueue\Queue\Beanstalk( $this->client, $name, $timeout );
+			$timeout = $this->getConfig('readtimeout', 30);
+			$this->queues[$name] = new \Aimeos\MW\MQueue\Queue\Beanstalk($this->client, $name, $timeout);
 		}
 
 		return $this->queues[$name];
@@ -69,11 +69,11 @@ 
 	 * @param integer $port Port the server is listening
 	 * @return \Pheanstalk\PheanstalkInterface|\Pheanstalk\Exception
 	 */
-	protected function connect( $host, $port )
+	protected function connect($host, $port)
 	{
-		$conntimeout = $this->getConfig( 'conntimeout', 3 );
-		$persist = $this->getConfig( 'persist', false );
+		$conntimeout = $this->getConfig('conntimeout', 3);
+		$persist = $this->getConfig('persist', false);
 
-		return new \Pheanstalk\Pheanstalk( $host, $port, $conntimeout, $persist );
+		return new \Pheanstalk\Pheanstalk($host, $port, $conntimeout, $persist);
 	}
 }
\ No newline at end of file

Braces +1 added lines, -2 removed lines

@@ -32,8 +32,7 @@
 					break;
 				}
 			}
-		}
-		else
+		} else
 		{
 			$this->client = $this->connect( $host, $port );
 		}

lib/custom/src/MW/MQueue/Message/Stomp.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
 	 *
 	 * @param \StompFrame $msg Stomp frame object
 	 */
-	public function __construct( \StompFrame $msg )
+	public function __construct(\StompFrame $msg)
 	{
 		$this->msg = $msg;
 	}

lib/custom/src/MW/MQueue/Message/Beanstalk.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
 	 *
 	 * @param \Pheanstalk\Job $job Job object
 	 */
-	public function __construct( \Pheanstalk\Job $job )
+	public function __construct(\Pheanstalk\Job $job)
 	{
 		$this->job = $job;
 	}

lib/custom/src/MW/MQueue/Message/AMQP.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
 	 *
 	 * @param \PhpAmqpLib\Message\AMQPMessage $msg AMQPMessage object
 	 */
-	public function __construct( \PhpAmqpLib\Message\AMQPMessage $msg )
+	public function __construct(\PhpAmqpLib\Message\AMQPMessage $msg)
 	{
 		$this->msg = $msg;
 	}

lib/custom/src/MW/MQueue/AMQP.php

Spacing +32 added lines, -32 removed lines

@@ -14,37 +14,37 @@ 
 	 *
 	 * @param array $config Associative list of configuration key/value pairs
 	 */
-	public function __construct( array $config )
+	public function __construct(array $config)
 	{
-		parent::__construct( $config );
+		parent::__construct($config);
 
-		$host = $this->getConfig( 'host', 'localhost' );
-		$port = $this->getConfig( 'port', 5672 );
-		$user = $this->getConfig( 'username', 'guest' );
-		$pass = $this->getConfig( 'password', 'guest' );
+		$host = $this->getConfig('host', 'localhost');
+		$port = $this->getConfig('port', 5672);
+		$user = $this->getConfig('username', 'guest');
+		$pass = $this->getConfig('password', 'guest');
 
-		if( is_array( $host ) )
+		if (is_array($host))
 		{
-			foreach( $host as $idx => $entry )
+			foreach ($host as $idx => $entry)
 			{
-				$iport = ( is_array( $port) ? $port[$idx] : $port );
-				$iuser = ( is_array( $user) ? $user[$idx] : $user );
-				$ipass = ( is_array( $pass) ? $pass[$idx] : $pass );
+				$iport = (is_array($port) ? $port[$idx] : $port);
+				$iuser = (is_array($user) ? $user[$idx] : $user);
+				$ipass = (is_array($pass) ? $pass[$idx] : $pass);
 
-				$this->conn = $this->connect( $entry, $iport, $iuser, $ipass );
+				$this->conn = $this->connect($entry, $iport, $iuser, $ipass);
 
-				if( $this->conn instanceof \PhpAmqpLib\Connection\AMQPStreamConnection ) {
+				if ($this->conn instanceof \PhpAmqpLib\Connection\AMQPStreamConnection) {
 					break;
 				}
 			}
 		}
 		else
 		{
-			$this->conn = $this->connect( $host, $port, $user, $pass );
+			$this->conn = $this->connect($host, $port, $user, $pass);
 		}
 
-		if( $this->conn instanceof \Exception ) {
-			throw new \Aimeos\MW\MQueue\Exception( $this->conn->getMessage() );
+		if ($this->conn instanceof \Exception) {
+			throw new \Aimeos\MW\MQueue\Exception($this->conn->getMessage());
 		}
 	}
 
@@ -64,19 +64,19 @@ 
 	 * @param string $name Queue name
 	 * @return \Aimeos\MW\MQueue\Queue\Iface Message queue
 	 */
-	public function getQueue( $name )
+	public function getQueue($name)
 	{
 		try
 		{
-			if( !isset( $this->queues[$name] ) ) {
-				$this->queues[$name] = new \Aimeos\MW\MQueue\Queue\AMQP( $this->getChannel(), $name );
+			if (!isset($this->queues[$name])) {
+				$this->queues[$name] = new \Aimeos\MW\MQueue\Queue\AMQP($this->getChannel(), $name);
 			}
 
 			return $this->queues[$name];
 		}
-		catch( \Exception $e )
+		catch (\Exception $e)
 		{
-			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
+			throw new \Aimeos\MW\MQueue\Exception($e->getMessage());
 		}
 	}
 
@@ -90,17 +90,17 @@ 
 	 * @param string $pass Password for authentication
 	 * @return \PhpAmqpLib\Connection\AMQPStreamConnection|\PhpAmqpLib\Exception\AMQPException
 	 */
-	protected function connect( $host, $port, $user, $pass )
+	protected function connect($host, $port, $user, $pass)
 	{
-		$vhost = $this->getConfig( 'vhost', '/' );
-		$insist = $this->getConfig( 'insist', false );
-		$loginMethod = $this->getConfig( 'login_method', 'AMQPLAIN' );
-		$loginResponse = $this->getConfig( 'login_response', null );
-		$locale = $this->getConfig( 'locale', 'en_US' );
-		$conntimeout = $this->getConfig( 'connection_timeout', 3.0 );
-		$timeout = $this->getConfig( 'read_write_timeout', 3.0 );
-		$keepalive = $this->getConfig( 'keepalive', false );
-		$heartbeat = $this->getConfig( 'heartbeat', 0 );
+		$vhost = $this->getConfig('vhost', '/');
+		$insist = $this->getConfig('insist', false);
+		$loginMethod = $this->getConfig('login_method', 'AMQPLAIN');
+		$loginResponse = $this->getConfig('login_response', null);
+		$locale = $this->getConfig('locale', 'en_US');
+		$conntimeout = $this->getConfig('connection_timeout', 3.0);
+		$timeout = $this->getConfig('read_write_timeout', 3.0);
+		$keepalive = $this->getConfig('keepalive', false);
+		$heartbeat = $this->getConfig('heartbeat', 0);
 
 		try
 		{
@@ -111,7 +111,7 @@ 
 				$keepalive, $heartbeat
 			);
 		}
-		catch( \Exception $e )
+		catch (\Exception $e)
 		{
 			return $e;
 		}

Braces +3 added lines, -6 removed lines

@@ -37,8 +37,7 @@ 
 					break;
 				}
 			}
-		}
-		else
+		} else
 		{
 			$this->conn = $this->connect( $host, $port, $user, $pass );
 		}
@@ -73,8 +72,7 @@ 
 			}
 
 			return $this->queues[$name];
-		}
-		catch( \Exception $e )
+		} catch( \Exception $e )
 		{
 			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
 		}
@@ -110,8 +108,7 @@ 
 				$locale, $conntimeout, $timeout, null,
 				$keepalive, $heartbeat
 			);
-		}
-		catch( \Exception $e )
+		} catch( \Exception $e )
 		{
 			return $e;
 		}