contamobi / CmobiRabbitmqBundle

DependencyInjection/CmobiRabbitmqExtension.php

Spacing +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
 
     public function load(array $configs, ContainerBuilder $container)
     {
-        $fileLocator = new FileLocator(__DIR__ . '/../Resources/config');
+        $fileLocator = new FileLocator(__DIR__.'/../Resources/config');
         $loader = new YamlFileLoader($container, $fileLocator);
         $loader->load('rabbitmq.yml');
 

Amqp/ConnectionFactory.php

Spacing +3 added lines, -3 removed lines

@@ -62,10 +62,10 @@
             $this->parameters['user'],
             $this->parameters['password'],
             $this->parameters['vhost'],
-            false,      // insist
+            false, // insist
             'AMQPLAIN', // login_method
-            null,       // login_response
-            'en_US',    // locale
+            null, // login_response
+            'en_US', // locale
             $this->parameters['connection_timeout'],
             $this->parameters['read_write_timeout'],
             $this->parameters['ssl_context'],

Rpc/RpcServer.php

Spacing +2 added lines, -2 removed lines

@@ -65,7 +65,7 @@ 
 
             if (!$service instanceof RpcServiceInterface) {
                 throw new InvalidRpcServerClassException(
-                    'Failed start RpcServer: %s is not instance of RpcServiceInterface'. $serviceName
+                    'Failed start RpcServer: %s is not instance of RpcServiceInterface'.$serviceName
                 );
             }
             list(
@@ -84,7 +84,7 @@ 
             );
         }
 
-        while(count($this->getChannel()->callbacks)) {
+        while (count($this->getChannel()->callbacks)) {
             $this->getChannel()->wait();
         }
 

Tests/app/AppKernel.php

Spacing +1 added lines, -1 removed lines

@@ -15,6 +15,6 @@
 
     public function registerContainerConfiguration(LoaderInterface $loader)
     {
-        $loader->load(__DIR__ . '/config/config.yml');
+        $loader->load(__DIR__.'/config/config.yml');
     }
 }
\ No newline at end of file

Routing/MethodCollection.php

Spacing +1 added lines, -1 removed lines

@@ -48,7 +48,7 @@
      */
     public function remove($name)
     {
-        foreach ((array) $name as $n) {
+        foreach ((array)$name as $n) {
             unset($this->methods[$n]);
         }
     }

Routing/Method.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
         $this->setDefaults($data['defaults']);
 
         if (isset($data['compiled'])) {
-            $this->compiled =$data['compiled'];
+            $this->compiled = $data['compiled'];
         }
     }
 

Routing/MethodRouter.php

Spacing +1 added lines, -1 removed lines

@@ -147,7 +147,7 @@
         $that = $this;
 
         $cache = $this->getConfigCacheFactory()->cache($this->options['cache_dir'].'/'.$class.'.php',
-            function (ConfigCacheInterface $cache) use ($that, $class) {
+            function(ConfigCacheInterface $cache) use ($that, $class) {
                 $dumper = $that->getMatcherDumperInstance();
 
                 $options = array(

Routing/MethodLoader.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
     {
         $collection = new MethodCollection();
         $root = $this->getContainer()->getParameter('kernel.root_dir');
-        $resource = $root . DIRECTORY_SEPARATOR . 'app' . DIRECTORY_SEPARATOR . 'config' . DIRECTORY_SEPARATOR . 'rpc_routing.yml';
+        $resource = $root.DIRECTORY_SEPARATOR.'app'.DIRECTORY_SEPARATOR.'config'.DIRECTORY_SEPARATOR.'rpc_routing.yml';
         $type = 'yaml';
         $importedRouters = $this->import($resource, $type);
         $collection->addCollection($importedRouters);

Rpc/BaseService.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
      */
     public function createCallback()
     {
-        $callback = function (AMQPMessage $message) {
+        $callback = function(AMQPMessage $message) {
 
             $responseCollection = $this->rpcMessager->getResponseCollection();
             $requestCollection = $this->rpcMessager->getRequestCollection();