aimeos / ai-mqueue

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

Doc Comments +2 added lines, -2 removed lines

@@ -67,7 +67,7 @@ 
 	/**
 	 * Removes the message from the queue
 	 *
-	 * @param \Aimeos\MW\MQueue\Message\Iface $msg Message object
+	 * @param \Aimeos\MW\MQueue\Message\AMQP $msg Message object
 	 * @throws \Aimeos\MW\MQueue\Exception
 	 */
 	public function del( \Aimeos\MW\MQueue\Message\Iface $msg )
@@ -83,7 +83,7 @@ 
 	/**
 	 * Returns the next message from the queue
 	 *
-	 * @return \Aimeos\MW\MQueue\Message\Iface|null Message object or null if none is available
+	 * @return \Aimeos\MW\MQueue\Message\AMQP|null Message object or null if none is available
 	 * @throws \Aimeos\MW\MQueue\Exception
 	 */
 	public function get()

Spacing +19 added lines, -19 removed lines

@@ -16,16 +16,16 @@ 
 	 * @param string $queue Message queue name
 	 * @throws \Aimeos\MW\MQueue\Exception
 	 */
-	public function __construct( \PhpAmqpLib\Channel\AMQPChannel $channel, $queue )
+	public function __construct(\PhpAmqpLib\Channel\AMQPChannel $channel, $queue)
 	{
 		try
 		{
-			$channel->queue_declare( $queue, false, true, false, false );
-			$channel->basic_qos( null, 1, null );
+			$channel->queue_declare($queue, false, true, false, false);
+			$channel->basic_qos(null, 1, null);
 		}
-		catch( \Exception $e )
+		catch (\Exception $e)
 		{
-			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
+			throw new \Aimeos\MW\MQueue\Exception($e->getMessage());
 		}
 
 		$this->channel = $channel;
@@ -40,7 +40,7 @@ 
 	{
 		try {
 			$this->channel->close();
-		} catch( \Exception $e ) { ; }
+		} catch (\Exception $e) {; }
 	}
 
 
@@ -50,16 +50,16 @@ 
 	 * @param string $msg Message, e.g. JSON encoded data
 	 * @throws \Aimeos\MW\MQueue\Exception
 	 */
-	public function add( $msg )
+	public function add($msg)
 	{
 		try
 		{
-			$message = new \PhpAmqpLib\Message\AMQPMessage( $msg, array( 'delivery_mode' => 2 ) );
-			$this->channel->basic_publish( $message, '', $this->queue );
+			$message = new \PhpAmqpLib\Message\AMQPMessage($msg, array('delivery_mode' => 2));
+			$this->channel->basic_publish($message, '', $this->queue);
 		}
-		catch( \Exception $e )
+		catch (\Exception $e)
 		{
-			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
+			throw new \Aimeos\MW\MQueue\Exception($e->getMessage());
 		}
 	}
 
@@ -70,12 +70,12 @@ 
 	 * @param \Aimeos\MW\MQueue\Message\Iface $msg Message object
 	 * @throws \Aimeos\MW\MQueue\Exception
 	 */
-	public function del( \Aimeos\MW\MQueue\Message\Iface $msg )
+	public function del(\Aimeos\MW\MQueue\Message\Iface $msg)
 	{
 		try {
-			$this->channel->basic_ack( $msg->getObject()->delivery_info['delivery_tag'] );
-		} catch( \Exception $e ) {
-			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
+			$this->channel->basic_ack($msg->getObject()->delivery_info['delivery_tag']);
+		} catch (\Exception $e) {
+			throw new \Aimeos\MW\MQueue\Exception($e->getMessage());
 		}
 	}
 
@@ -90,13 +90,13 @@ 
 	{
 		try
 		{
-			if( ( $msg = $this->channel->basic_get( $this->queue ) ) !== null ) {
-				return new \Aimeos\MW\MQueue\Message\AMQP( $msg );
+			if (($msg = $this->channel->basic_get($this->queue)) !== null) {
+				return new \Aimeos\MW\MQueue\Message\AMQP($msg);
 			}
 		}
-		catch( \Exception $e )
+		catch (\Exception $e)
 		{
-			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
+			throw new \Aimeos\MW\MQueue\Exception($e->getMessage());
 		}
 	}
 }

Braces +3 added lines, -6 removed lines

@@ -22,8 +22,7 @@ 
 		{
 			$channel->queue_declare( $queue, false, true, false, false );
 			$channel->basic_qos( null, 1, null );
-		}
-		catch( \Exception $e )
+		} catch( \Exception $e )
 		{
 			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
 		}
@@ -56,8 +55,7 @@ 
 		{
 			$message = new \PhpAmqpLib\Message\AMQPMessage( $msg, array( 'delivery_mode' => 2 ) );
 			$this->channel->basic_publish( $message, '', $this->queue );
-		}
-		catch( \Exception $e )
+		} catch( \Exception $e )
 		{
 			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
 		}
@@ -93,8 +91,7 @@ 
 			if( ( $msg = $this->channel->basic_get( $this->queue ) ) !== null ) {
 				return new \Aimeos\MW\MQueue\Message\AMQP( $msg );
 			}
-		}
-		catch( \Exception $e )
+		} catch( \Exception $e )
 		{
 			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
 		}

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

Doc Comments +2 added lines, -2 removed lines

@@ -53,7 +53,7 @@ 
 	/**
 	 * Removes the message from the queue
 	 *
-	 * @param \Aimeos\MW\MQueue\Message\Iface $msg Message object
+	 * @param \Aimeos\MW\MQueue\Message\Stomp $msg Message object
 	 * @throws \Aimeos\MW\MQueue\Exception
 	 */
 	public function del( \Aimeos\MW\MQueue\Message\Iface $msg )
@@ -67,7 +67,7 @@ 
 	/**
 	 * Returns the next message from the queue
 	 *
-	 * @return \Aimeos\MW\MQueue\Message\Iface|null Message object or null if none is available
+	 * @return \Aimeos\MW\MQueue\Message\Stomp|null Message object or null if none is available
 	 * @throws \Aimeos\MW\MQueue\Exception
 	 */
 	public function get()

Spacing +14 added lines, -14 removed lines

@@ -16,10 +16,10 @@ 
 	 * @param string $queue Message queue name
 	 * @throws \Aimeos\MW\MQueue\Exception
 	 */
-	public function __construct( \Stomp $client, $queue )
+	public function __construct(\Stomp $client, $queue)
 	{
-		if( $client->subscribe( $queue ) === false ) {
-			throw new \Aimeos\MW\MQueue\Exception( $client->error() );
+		if ($client->subscribe($queue) === false) {
+			throw new \Aimeos\MW\MQueue\Exception($client->error());
 		}
 
 		$this->client = $client;
@@ -32,7 +32,7 @@ 
 	 */
 	public function __destruct()
 	{
-		$this->client->unsubscribe( $this->queue );
+		$this->client->unsubscribe($this->queue);
 	}
 
 
@@ -42,10 +42,10 @@ 
 	 * @param string $msg Message, e.g. JSON encoded data
 	 * @throws \Aimeos\MW\MQueue\Exception
 	 */
-	public function add( $msg )
+	public function add($msg)
 	{
-		if( $this->client->send( $this->queue, $msg ) === false ) {
-			throw new \Aimeos\MW\MQueue\Exception( $this->client->error() );
+		if ($this->client->send($this->queue, $msg) === false) {
+			throw new \Aimeos\MW\MQueue\Exception($this->client->error());
 		}
 	}
 
@@ -56,10 +56,10 @@ 
 	 * @param \Aimeos\MW\MQueue\Message\Iface $msg Message object
 	 * @throws \Aimeos\MW\MQueue\Exception
 	 */
-	public function del( \Aimeos\MW\MQueue\Message\Iface $msg )
+	public function del(\Aimeos\MW\MQueue\Message\Iface $msg)
 	{
-		if( $this->client->ack( $msg->getObject() ) === false ) {
-			throw new \Aimeos\MW\MQueue\Exception( $this->client->error() );
+		if ($this->client->ack($msg->getObject()) === false) {
+			throw new \Aimeos\MW\MQueue\Exception($this->client->error());
 		}
 	}
 
@@ -74,13 +74,13 @@ 
 	{
 		try
 		{
-			if( $this->client->hasFrame() ) {
-				return new \Aimeos\MW\MQueue\Message\Stomp( $this->client->readFrame() );
+			if ($this->client->hasFrame()) {
+				return new \Aimeos\MW\MQueue\Message\Stomp($this->client->readFrame());
 			}
 		}
-		catch( \StompException $e )
+		catch (\StompException $e)
 		{
-			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
+			throw new \Aimeos\MW\MQueue\Exception($e->getMessage());
 		}
 	}
 }
\ No newline at end of file

Braces +1 added lines, -2 removed lines

@@ -77,8 +77,7 @@
 			if( $this->client->hasFrame() ) {
 				return new \Aimeos\MW\MQueue\Message\Stomp( $this->client->readFrame() );
 			}
-		}
-		catch( \StompException $e )
+		} catch( \StompException $e )
 		{
 			throw new \Aimeos\MW\MQueue\Exception( $e->getMessage() );
 		}

lib/custom/tests/TestHelper.php

Spacing +24 added lines, -24 removed lines

@@ -18,14 +18,14 @@ 
 
 		$includepaths = $aimeos->getIncludePaths();
 		$includepaths[] = get_include_path();
-		set_include_path( implode( PATH_SEPARATOR, $includepaths ) );
+		set_include_path(implode(PATH_SEPARATOR, $includepaths));
 	}
 
 
-	public static function getContext( $site = 'unittest' )
+	public static function getContext($site = 'unittest')
 	{
-		if( !isset( self::$context[$site] ) ) {
-			self::$context[$site] = self::createContext( $site );
+		if (!isset(self::$context[$site])) {
+			self::$context[$site] = self::createContext($site);
 		}
 
 		return clone self::$context[$site];
@@ -34,58 +34,58 @@ 
 
 	private static function getAimeos()
 	{
-		if( !isset( self::$aimeos ) )
+		if (!isset(self::$aimeos))
 		{
 			require_once 'Bootstrap.php';
-			spl_autoload_register( 'Aimeos\\Bootstrap::autoload' );
+			spl_autoload_register('Aimeos\\Bootstrap::autoload');
 
-			$extdir = dirname( dirname( dirname( __DIR__ ) ) );
-			self::$aimeos = new \Aimeos\Bootstrap( array( $extdir ), false );
+			$extdir = dirname(dirname(dirname(__DIR__)));
+			self::$aimeos = new \Aimeos\Bootstrap(array($extdir), false);
 		}
 
 		return self::$aimeos;
 	}
 
 
-	private static function createContext( $site )
+	private static function createContext($site)
 	{
 		$ctx = new \Aimeos\MShop\Context\Item\Standard();
 		$aimeos = self::getAimeos();
 
 
-		$paths = $aimeos->getConfigPaths( 'mysql' );
+		$paths = $aimeos->getConfigPaths('mysql');
 		$paths[] = __DIR__ . DIRECTORY_SEPARATOR . 'config';
 
-		$conf = new \Aimeos\MW\Config\PHPArray( array(), $paths );
-		$ctx->setConfig( $conf );
+		$conf = new \Aimeos\MW\Config\PHPArray(array(), $paths);
+		$ctx->setConfig($conf);
 
 
-		$dbm = new \Aimeos\MW\DB\Manager\PDO( $conf );
-		$ctx->setDatabaseManager( $dbm );
+		$dbm = new \Aimeos\MW\DB\Manager\PDO($conf);
+		$ctx->setDatabaseManager($dbm);
 
 
-		$logger = new \Aimeos\MW\Logger\File( $site . '.log', \Aimeos\MW\Logger\Base::DEBUG );
-		$ctx->setLogger( $logger );
+		$logger = new \Aimeos\MW\Logger\File($site . '.log', \Aimeos\MW\Logger\Base::DEBUG);
+		$ctx->setLogger($logger);
 
 
 		$cache = new \Aimeos\MW\Cache\None();
-		$ctx->setCache( $cache );
+		$ctx->setCache($cache);
 
 
-		$i18n = new \Aimeos\MW\Translation\None( 'de' );
-		$ctx->setI18n( array( 'de' => $i18n ) );
+		$i18n = new \Aimeos\MW\Translation\None('de');
+		$ctx->setI18n(array('de' => $i18n));
 
 
 		$session = new \Aimeos\MW\Session\None();
-		$ctx->setSession( $session );
+		$ctx->setSession($session);
 
 
-		$localeManager = \Aimeos\MShop\Locale\Manager\Factory::createManager( $ctx );
-		$localeItem = $localeManager->bootstrap( $site, '', '', false );
+		$localeManager = \Aimeos\MShop\Locale\Manager\Factory::createManager($ctx);
+		$localeItem = $localeManager->bootstrap($site, '', '', false);
 
-		$ctx->setLocale( $localeItem );
+		$ctx->setLocale($localeItem);
 
-		$ctx->setEditor( 'ai-mqueue:unittest' );
+		$ctx->setEditor('ai-mqueue:unittest');
 
 		return $ctx;
 	}

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

Spacing +17 added lines, -17 removed lines

@@ -7,8 +7,8 @@ 
 {
 	protected function setUp()
 	{
-		if( class_exists( '\Pheanstalk\Pheanstalk' ) === false ) {
-			$this->markTestSkipped( 'Please install the "pheanstalk" library via composer first' );
+		if (class_exists('\Pheanstalk\Pheanstalk') === false) {
+			$this->markTestSkipped('Please install the "pheanstalk" library via composer first');
 		}
 	}
 
@@ -17,42 +17,42 @@ 
 	{
 		try
 		{
-			$mqueue = new \Aimeos\MW\MQueue\Beanstalk( array( 'conntimeout' => 1, 'readtimeout' => 1 ) );
-			$queue = $mqueue->getQueue( 'aimeos_unittest' );
+			$mqueue = new \Aimeos\MW\MQueue\Beanstalk(array('conntimeout' => 1, 'readtimeout' => 1));
+			$queue = $mqueue->getQueue('aimeos_unittest');
 		}
-		catch( \Aimeos\MW\MQueue\Exception $e )
+		catch (\Aimeos\MW\MQueue\Exception $e)
 		{
-			$this->markTestSkipped( 'No Stomp compliant server available at "localhost"' );
+			$this->markTestSkipped('No Stomp 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()
 	{
-		$object = new \Aimeos\MW\MQueue\Beanstalk( array( 'host' => '192.168.255.255',  'conntimeout' => 1 ) );
-		$this->assertInstanceOf( '\Aimeos\MW\MQueue\Iface', $object );
+		$object = new \Aimeos\MW\MQueue\Beanstalk(array('host' => '192.168.255.255', 'conntimeout' => 1));
+		$this->assertInstanceOf('\Aimeos\MW\MQueue\Iface', $object);
 	}
 
 
 	public function testMultiConnection()
 	{
-		$config = array( 'host' => array( '192.168.254.255', '192.168.255.255' ),  'conntimeout' => 1 );
-		$object = new \Aimeos\MW\MQueue\Beanstalk( $config );
-		$this->assertInstanceOf( '\Aimeos\MW\MQueue\Iface', $object );
+		$config = array('host' => array('192.168.254.255', '192.168.255.255'), 'conntimeout' => 1);
+		$object = new \Aimeos\MW\MQueue\Beanstalk($config);
+		$this->assertInstanceOf('\Aimeos\MW\MQueue\Iface', $object);
 	}
 
 
 	public function testGetQueue()
 	{
-		$object = new \Aimeos\MW\MQueue\Beanstalk( array( 'host' => '192.168.255.255',  'conntimeout' => 1 ) );
+		$object = new \Aimeos\MW\MQueue\Beanstalk(array('host' => '192.168.255.255', 'conntimeout' => 1));
 
-		$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\Beanstalk( array( 'conntimeout' => 1, 'readtimeout' => 1 ) );
 			$queue = $mqueue->getQueue( 'aimeos_unittest' );
-		}
-		catch( \Aimeos\MW\MQueue\Exception $e )
+		} catch( \Aimeos\MW\MQueue\Exception $e )
 		{
 			$this->markTestSkipped( 'No Stomp compliant server available at "localhost"' );
 		}

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

Spacing +18 added lines, -18 removed lines

@@ -7,8 +7,8 @@ 
 {
 	protected function setUp()
 	{
-		if( class_exists( '\Stomp' ) === false ) {
-			$this->markTestSkipped( 'Please install the "stomp" PHP extension first' );
+		if (class_exists('\Stomp') === false) {
+			$this->markTestSkipped('Please install the "stomp" PHP extension first');
 		}
 	}
 
@@ -17,49 +17,49 @@ 
 	{
 		try
 		{
-			$config = array( 'username' => 'guest', 'password' => 'guest' );
-			$mqueue = new \Aimeos\MW\MQueue\Stomp( $config );
-			$queue = $mqueue->getQueue( 'aimeos_unittest' );
+			$config = array('username' => 'guest', 'password' => 'guest');
+			$mqueue = new \Aimeos\MW\MQueue\Stomp($config);
+			$queue = $mqueue->getQueue('aimeos_unittest');
 		}
-		catch( \Aimeos\MW\MQueue\Exception $e )
+		catch (\Aimeos\MW\MQueue\Exception $e)
 		{
-			$this->markTestSkipped( 'No Stomp compliant server available at "localhost"' );
+			$this->markTestSkipped('No Stomp 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 testGetQueueSingleConnection()
 	{
-		$object = new \Aimeos\MW\MQueue\Stomp( array( 'host' => 'tcp://127.0.0.1:61616' ) );
+		$object = new \Aimeos\MW\MQueue\Stomp(array('host' => 'tcp://127.0.0.1:61616'));
 	}
 
 
 	public function testGetQueueMultiConnection()
 	{
-		$object = new \Aimeos\MW\MQueue\Stomp( array( 'host' => array( 'tcp://127.0.0.1:61616', 'tcp://127.0.0.1:61617' ) ) );
+		$object = new \Aimeos\MW\MQueue\Stomp(array('host' => array('tcp://127.0.0.1:61616', 'tcp://127.0.0.1:61617')));
 	}
 
 
 	public function testGetQueue()
 	{
-		$client = $this->getMockBuilder( '\Stomp' )
+		$client = $this->getMockBuilder('\Stomp')
 			->disableOriginalConstructor()
 			->getMock();
 
-		$object = $this->getMockBuilder( '\Aimeos\MW\MQueue\Stomp' )
-			->setMethods( array( 'connect' ) )
+		$object = $this->getMockBuilder('\Aimeos\MW\MQueue\Stomp')
+			->setMethods(array('connect'))
 			->disableOriginalConstructor()
 			->getMock();
 
-		$object->expects( $this->once() )->method( 'connect' )
-			->will( $this->returnValue( $client ) );
+		$object->expects($this->once())->method('connect')
+			->will($this->returnValue($client));
 
-		$this->assertInstanceOf( '\Aimeos\MW\MQueue\Queue\Iface', $object->getQueue( 'test' ) );
+		$this->assertInstanceOf('\Aimeos\MW\MQueue\Queue\Iface', $object->getQueue('test'));
 	}
 }

Braces +1 added lines, -2 removed lines

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

lib/custom/tests/MW/MQueue/Queue/BeanstalkTest.php

Spacing +35 added lines, -35 removed lines

@@ -11,96 +11,96 @@
 
 	protected function setUp()
 	{
-		if( class_exists( '\Pheanstalk\Pheanstalk' ) === false ) {
-			$this->markTestSkipped( 'Please install the "pheanstalk" library via composer first' );
+		if (class_exists('\Pheanstalk\Pheanstalk') === false) {
+			$this->markTestSkipped('Please install the "pheanstalk" library via composer first');
 		}
 
-		$this->mock = $this->getMockBuilder( '\Pheanstalk\Pheanstalk' )
-			->setMethods( array( 'useTube', 'watch', 'put', 'delete', 'reserve' ) )
+		$this->mock = $this->getMockBuilder('\Pheanstalk\Pheanstalk')
+			->setMethods(array('useTube', 'watch', 'put', 'delete', 'reserve'))
 			->disableOriginalConstructor()
 			->getMock();
 
-		$this->mock->expects( $this->any() )->method( 'useTube' )
-			->will( $this->returnValue( $this->mock ) );
+		$this->mock->expects($this->any())->method('useTube')
+			->will($this->returnValue($this->mock));
 
-		$this->object = new \Aimeos\MW\MQueue\Queue\Beanstalk( $this->mock, 'test' );
+		$this->object = new \Aimeos\MW\MQueue\Queue\Beanstalk($this->mock, 'test');
 	}
 
 
 	protected function tearDown()
 	{
-		unset( $this->object );
+		unset($this->object);
 	}
 
 
 	public function testConstructorException()
 	{
-		$this->mock->expects( $this->once() )->method( 'watch' )
-			->will( $this->throwException( new \Pheanstalk\Exception() ) );
+		$this->mock->expects($this->once())->method('watch')
+			->will($this->throwException(new \Pheanstalk\Exception()));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		new \Aimeos\MW\MQueue\Queue\Beanstalk( $this->mock, 'test' );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		new \Aimeos\MW\MQueue\Queue\Beanstalk($this->mock, 'test');
 	}
 
 
 	public function testAdd()
 	{
-		$this->mock->expects( $this->once() )->method( 'put' );
+		$this->mock->expects($this->once())->method('put');
 
-		$this->object->add( 'test' );
+		$this->object->add('test');
 	}
 
 
 	public function testAddException()
 	{
-		$this->mock->expects( $this->once() )->method( 'put' )
-			->will( $this->throwException( new \Pheanstalk\Exception() ) );
+		$this->mock->expects($this->once())->method('put')
+			->will($this->throwException(new \Pheanstalk\Exception()));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		$this->object->add( 'test' );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		$this->object->add('test');
 	}
 
 
 	public function testDel()
 	{
-		$msg = new \Pheanstalk\Job( 1, 'test' );
-		$message = new \Aimeos\MW\MQueue\Message\Beanstalk( $msg );
+		$msg = new \Pheanstalk\Job(1, 'test');
+		$message = new \Aimeos\MW\MQueue\Message\Beanstalk($msg);
 
-		$this->mock->expects( $this->once() )->method( 'delete' );
+		$this->mock->expects($this->once())->method('delete');
 
-		$this->object->del( $message );
+		$this->object->del($message);
 	}
 
 
 	public function testDelException()
 	{
-		$msg = new \Pheanstalk\Job( 1, 'test' );
-		$message = new \Aimeos\MW\MQueue\Message\Beanstalk( $msg );
+		$msg = new \Pheanstalk\Job(1, 'test');
+		$message = new \Aimeos\MW\MQueue\Message\Beanstalk($msg);
 
-		$this->mock->expects( $this->once() )->method( 'delete' )
-			->will( $this->throwException( new \Pheanstalk\Exception() ) );
+		$this->mock->expects($this->once())->method('delete')
+			->will($this->throwException(new \Pheanstalk\Exception()));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		$this->object->del( $message );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		$this->object->del($message);
 	}
 
 
 	public function testGet()
 	{
-		$msg = new \Pheanstalk\Job( 1, 'test' );
+		$msg = new \Pheanstalk\Job(1, 'test');
 
-		$this->mock->expects( $this->once() )->method( 'reserve' )
-			->will( $this->returnValue( $msg ) );
+		$this->mock->expects($this->once())->method('reserve')
+			->will($this->returnValue($msg));
 
-		$this->assertInstanceOf( '\Aimeos\MW\MQueue\Message\Iface', $this->object->get() );
+		$this->assertInstanceOf('\Aimeos\MW\MQueue\Message\Iface', $this->object->get());
 	}
 
 
 	public function testGetNone()
 	{
-		$this->mock->expects( $this->once() )->method( 'reserve' )
-			->will( $this->returnValue( false ) );
+		$this->mock->expects($this->once())->method('reserve')
+			->will($this->returnValue(false));
 
-		$this->assertNull( $this->object->get() );
+		$this->assertNull($this->object->get());
 	}
 }

lib/custom/tests/MW/MQueue/Queue/StompTest.php

Spacing +44 added lines, -44 removed lines

@@ -11,115 +11,115 @@
 
 	protected function setUp()
 	{
-		if( class_exists( '\Stomp' ) === false ) {
-			$this->markTestSkipped( 'Please install the "Stomp" PHP extension first' );
+		if (class_exists('\Stomp') === false) {
+			$this->markTestSkipped('Please install the "Stomp" PHP extension first');
 		}
 
-		$this->mock = $this->getMockBuilder( '\Stomp' )
-			->setMethods( array( 'subscribe', 'unsubscribe', 'send', 'ack', 'hasFrame', 'readFrame', 'error', '__destruct' ) )
+		$this->mock = $this->getMockBuilder('\Stomp')
+			->setMethods(array('subscribe', 'unsubscribe', 'send', 'ack', 'hasFrame', 'readFrame', 'error', '__destruct'))
 			->disableOriginalConstructor()
 			->getMock();
 
-		$this->object = new \Aimeos\MW\MQueue\Queue\Stomp( $this->mock, 'test' );
+		$this->object = new \Aimeos\MW\MQueue\Queue\Stomp($this->mock, 'test');
 	}
 
 
 	protected function tearDown()
 	{
-		unset( $this->object );
+		unset($this->object);
 	}
 
 
 	public function testConstructorException()
 	{
-		$this->mock->expects( $this->once() )->method( 'subscribe' )
-			->will( $this->returnValue( false ) );
+		$this->mock->expects($this->once())->method('subscribe')
+			->will($this->returnValue(false));
 
-		$this->mock->expects( $this->once() )->method( 'error' )
-			->will( $this->returnValue( 'exception' ) );
+		$this->mock->expects($this->once())->method('error')
+			->will($this->returnValue('exception'));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		new \Aimeos\MW\MQueue\Queue\Stomp( $this->mock, 'test' );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		new \Aimeos\MW\MQueue\Queue\Stomp($this->mock, 'test');
 	}
 
 
 	public function testAdd()
 	{
-		$this->mock->expects( $this->once() )->method( 'send' );
+		$this->mock->expects($this->once())->method('send');
 
-		$this->object->add( 'test' );
+		$this->object->add('test');
 	}
 
 
 	public function testAddException()
 	{
-		$this->mock->expects( $this->once() )->method( 'send' )
-			->will( $this->returnValue( false ) );
+		$this->mock->expects($this->once())->method('send')
+			->will($this->returnValue(false));
 
-		$this->mock->expects( $this->once() )->method( 'error' )
-			->will( $this->returnValue( 'exception' ) );
+		$this->mock->expects($this->once())->method('error')
+			->will($this->returnValue('exception'));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		$this->object->add( 'test' );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		$this->object->add('test');
 	}
 
 
 	public function testDel()
 	{
-		$msg = new \StompFrame( 'COMMAND', array(), 'test' );
-		$message = new \Aimeos\MW\MQueue\Message\Stomp( $msg );
+		$msg = new \StompFrame('COMMAND', array(), 'test');
+		$message = new \Aimeos\MW\MQueue\Message\Stomp($msg);
 
-		$this->mock->expects( $this->once() )->method( 'ack' );
+		$this->mock->expects($this->once())->method('ack');
 
-		$this->object->del( $message );
+		$this->object->del($message);
 	}
 
 
 	public function testDelException()
 	{
-		$msg = new \StompFrame( 'COMMAND', array(), 'test' );
-		$message = new \Aimeos\MW\MQueue\Message\Stomp( $msg );
+		$msg = new \StompFrame('COMMAND', array(), 'test');
+		$message = new \Aimeos\MW\MQueue\Message\Stomp($msg);
 
-		$this->mock->expects( $this->once() )->method( 'ack' )
-			->will( $this->returnValue( false ) );
+		$this->mock->expects($this->once())->method('ack')
+			->will($this->returnValue(false));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		$this->object->del( $message );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		$this->object->del($message);
 	}
 
 
 	public function testGet()
 	{
-		$msg = new \StompFrame( 'test' );
+		$msg = new \StompFrame('test');
 
-		$this->mock->expects( $this->once() )->method( 'hasFrame' )
-			->will( $this->returnValue( true ) );
+		$this->mock->expects($this->once())->method('hasFrame')
+			->will($this->returnValue(true));
 
-		$this->mock->expects( $this->once() )->method( 'readFrame' )
-			->will( $this->returnValue( $msg ) );
+		$this->mock->expects($this->once())->method('readFrame')
+			->will($this->returnValue($msg));
 
-		$this->assertInstanceOf( '\Aimeos\MW\MQueue\Message\Iface', $this->object->get() );
+		$this->assertInstanceOf('\Aimeos\MW\MQueue\Message\Iface', $this->object->get());
 	}
 
 
 	public function testGetNone()
 	{
-		$this->mock->expects( $this->once() )->method( 'hasFrame' )
-			->will( $this->returnValue( false ) );
+		$this->mock->expects($this->once())->method('hasFrame')
+			->will($this->returnValue(false));
 
-		$this->assertNull( $this->object->get() );
+		$this->assertNull($this->object->get());
 	}
 
 
 	public function testGetException()
 	{
-		$this->mock->expects( $this->once() )->method( 'hasFrame' )
-			->will( $this->returnValue( true ) );
+		$this->mock->expects($this->once())->method('hasFrame')
+			->will($this->returnValue(true));
 
-		$this->mock->expects( $this->once() )->method( 'readFrame' )
-			->will( $this->throwException( new \StompException() ) );
+		$this->mock->expects($this->once())->method('readFrame')
+			->will($this->throwException(new \StompException()));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
 		$this->object->get();
 	}
 }

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

Spacing +38 added lines, -38 removed lines

@@ -11,107 +11,107 @@
 
 	protected function setUp()
 	{
-		if( class_exists( '\PhpAmqpLib\Channel\AMQPChannel' ) === false ) {
-			$this->markTestSkipped( 'Please install the "php-amqplib" library via composer first' );
+		if (class_exists('\PhpAmqpLib\Channel\AMQPChannel') === false) {
+			$this->markTestSkipped('Please install the "php-amqplib" library via composer first');
 		}
 
-		$this->mock = $this->getMockBuilder( '\PhpAmqpLib\Channel\AMQPChannel' )
-			->setMethods( array( 'queue_declare', 'basic_qos', 'basic_publish', 'basic_get', 'basic_ack' ) )
+		$this->mock = $this->getMockBuilder('\PhpAmqpLib\Channel\AMQPChannel')
+			->setMethods(array('queue_declare', 'basic_qos', 'basic_publish', 'basic_get', 'basic_ack'))
 			->disableOriginalConstructor()
 			->getMock();
 
-		$this->object = new \Aimeos\MW\MQueue\Queue\AMQP( $this->mock, 'test' );
+		$this->object = new \Aimeos\MW\MQueue\Queue\AMQP($this->mock, 'test');
 	}
 
 
 	protected function tearDown()
 	{
-		unset( $this->object );
+		unset($this->object);
 	}
 
 
 	public function testConstructorException()
 	{
-		$this->mock->expects( $this->once() )->method( 'queue_declare' )
-			->will( $this->throwException( new \Exception() ) );
+		$this->mock->expects($this->once())->method('queue_declare')
+			->will($this->throwException(new \Exception()));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		new \Aimeos\MW\MQueue\Queue\AMQP( $this->mock, 'test' );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		new \Aimeos\MW\MQueue\Queue\AMQP($this->mock, 'test');
 	}
 
 
 	public function testAdd()
 	{
-		$this->mock->expects( $this->once() )->method( 'basic_publish' );
+		$this->mock->expects($this->once())->method('basic_publish');
 
-		$this->object->add( 'test' );
+		$this->object->add('test');
 	}
 
 
 	public function testAddException()
 	{
-		$this->mock->expects( $this->once() )->method( 'basic_publish' )
-			->will( $this->throwException( new \Exception() ) );
+		$this->mock->expects($this->once())->method('basic_publish')
+			->will($this->throwException(new \Exception()));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		$this->object->add( 'test' );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		$this->object->add('test');
 	}
 
 
 	public function testDel()
 	{
-		$msg = new \PhpAmqpLib\Message\AMQPMessage( 'test' );
-		$msg->delivery_info = array( 'channel' => $this->mock, 'delivery_tag' => 'test' );
+		$msg = new \PhpAmqpLib\Message\AMQPMessage('test');
+		$msg->delivery_info = array('channel' => $this->mock, 'delivery_tag' => 'test');
 
-		$message = new \Aimeos\MW\MQueue\Message\AMQP( $msg );
+		$message = new \Aimeos\MW\MQueue\Message\AMQP($msg);
 
-		$this->mock->expects( $this->once() )->method( 'basic_ack' );
+		$this->mock->expects($this->once())->method('basic_ack');
 
-		$this->object->del( $message );
+		$this->object->del($message);
 	}
 
 
 	public function testDelException()
 	{
-		$msg = new \PhpAmqpLib\Message\AMQPMessage( 'test' );
-		$msg->delivery_info = array( 'channel' => $this->mock, 'delivery_tag' => 'test' );
+		$msg = new \PhpAmqpLib\Message\AMQPMessage('test');
+		$msg->delivery_info = array('channel' => $this->mock, 'delivery_tag' => 'test');
 
-		$message = new \Aimeos\MW\MQueue\Message\AMQP( $msg );
+		$message = new \Aimeos\MW\MQueue\Message\AMQP($msg);
 
-		$this->mock->expects( $this->once() )->method( 'basic_ack' )
-			->will( $this->throwException( new \Exception() ) );
+		$this->mock->expects($this->once())->method('basic_ack')
+			->will($this->throwException(new \Exception()));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
-		$this->object->del( $message );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
+		$this->object->del($message);
 	}
 
 
 	public function testGet()
 	{
-		$msg = new \PhpAmqpLib\Message\AMQPMessage( 'test' );
+		$msg = new \PhpAmqpLib\Message\AMQPMessage('test');
 
-		$this->mock->expects( $this->once() )->method( 'basic_get' )
-			->will( $this->returnValue( $msg ) );
+		$this->mock->expects($this->once())->method('basic_get')
+			->will($this->returnValue($msg));
 
-		$this->assertInstanceOf( '\Aimeos\MW\MQueue\Message\Iface', $this->object->get() );
+		$this->assertInstanceOf('\Aimeos\MW\MQueue\Message\Iface', $this->object->get());
 	}
 
 
 	public function testGetNone()
 	{
-		$this->mock->expects( $this->once() )->method( 'basic_get' )
-			->will( $this->returnValue( null ) );
+		$this->mock->expects($this->once())->method('basic_get')
+			->will($this->returnValue(null));
 
-		$this->assertNull( $this->object->get() );
+		$this->assertNull($this->object->get());
 	}
 
 
 	public function testGetException()
 	{
-		$this->mock->expects( $this->once() )->method( 'basic_get' )
-			->will( $this->throwException( new \Exception() ) );
+		$this->mock->expects($this->once())->method('basic_get')
+			->will($this->throwException(new \Exception()));
 
-		$this->setExpectedException( '\Aimeos\MW\MQueue\Exception' );
+		$this->setExpectedException('\Aimeos\MW\MQueue\Exception');
 		$this->object->get();
 	}
 }

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

Spacing +7 added lines, -7 removed lines

@@ -10,29 +10,29 @@
 
 	protected function setUp()
 	{
-		if( class_exists( '\Pheanstalk\Job' ) === false ) {
-			$this->markTestSkipped( 'Please install the "pheanstalk" library via composer first' );
+		if (class_exists('\Pheanstalk\Job') === false) {
+			$this->markTestSkipped('Please install the "pheanstalk" library via composer first');
 		}
 
-		$msg = new \Pheanstalk\Job( 1, 'test' );
-		$this->object = new \Aimeos\MW\MQueue\Message\Beanstalk( $msg );
+		$msg = new \Pheanstalk\Job(1, 'test');
+		$this->object = new \Aimeos\MW\MQueue\Message\Beanstalk($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( '\Pheanstalk\Job', $this->object->getObject() );
+		$this->assertInstanceOf('\Pheanstalk\Job', $this->object->getObject());
 	}
 }