contamobi / CmobiRabbitmqBundle

Amqp/ConnectionFactory.php

Doc Comments +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
     ];
 
     /**
-     * @param $class string FQCN of AMQPConnection class to instantiate.
+     * @param string $class string FQCN of AMQPConnection class to instantiate.
      * @param array $parameters
      * @throws InvalidAMQPConnectionClassException
      */

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

Doc Comments +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
     }
 
     /**
-     * @param $queue
+     * @param string $queue
      * @param RpcServiceInterface $serviceCallback
      * @param bool|false $passive
      * @param bool|false $durable

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();
         }
 

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');
 

DependencyInjection/Configuration.php

Indentation +12 added lines, -12 removed lines

@@ -44,19 +44,19 @@
                     ->prototype('array')
                         ->children()
                             ->arrayNode('queue')
-                                     ->children()
-                                         ->scalarNode('name')->end()
-                                         ->booleanNode('passive')->defaultFalse()->end()
-                                         ->booleanNode('durable')->defaultTrue()->end()
-                                         ->booleanNode('exclusive')->defaultFalse()->end()
-                                         ->booleanNode('auto_delete')->defaultFalse()->end()
-                                         ->booleanNode('nowait')->defaultFalse()->end()
-                                         ->variableNode('arguments')->defaultNull()->end()
-                                         ->scalarNode('ticket')->defaultNull()->end()
-                                         ->arrayNode('routing_keys')
+                                        ->children()
+                                            ->scalarNode('name')->end()
+                                            ->booleanNode('passive')->defaultFalse()->end()
+                                            ->booleanNode('durable')->defaultTrue()->end()
+                                            ->booleanNode('exclusive')->defaultFalse()->end()
+                                            ->booleanNode('auto_delete')->defaultFalse()->end()
+                                            ->booleanNode('nowait')->defaultFalse()->end()
+                                            ->variableNode('arguments')->defaultNull()->end()
+                                            ->scalarNode('ticket')->defaultNull()->end()
+                                            ->arrayNode('routing_keys')
                                             ->prototype('scalar')->end()
-                                         ->end()
-                                     ->end()
+                                            ->end()
+                                        ->end()
                             ->end()
                             ->scalarNode('class')->end()
                             ->arrayNode('arguments')->end()

Rpc/RpcClient.php

Spacing +3 added lines, -3 removed lines

@@ -30,7 +30,7 @@ 
      */
     public function onResponse(AMQPMessage $rep)
     {
-        if($rep->get('correlation_id') == $this->correlationId) {
+        if ($rep->get('correlation_id') == $this->correlationId) {
             $this->response = $rep->body;
         }
     }
@@ -40,7 +40,7 @@ 
      */
     public function call()
     {
-        list($callbackQueue, ,) = $this->getChannel()->queue_declare(
+        list($callbackQueue,,) = $this->getChannel()->queue_declare(
             '', false, false, true, false
         );
         $this->callbackQueue = $callbackQueue;
@@ -60,7 +60,7 @@ 
         );
         $this->getChannel()->basic_publish($msg, '', $this->getQueueName());
 
-        while(!$this->response) {
+        while (!$this->response) {
             $this->getChannel()->wait();
         }
         return $this->response;

Doc Comments +1 added lines, -1 removed lines

@@ -164,7 +164,7 @@
     }
 
     /**
-     * @param $body
+     * @param string $body
      */
     private function handleRequest($body)
     {

Indentation +1 added lines, -1 removed lines

@@ -82,7 +82,7 @@
         }
         /* Send to Message Broker */
         $this->handleRequest($body);
-       $rpcResponse = $this->buildRpcResponseCollection();
+        $rpcResponse = $this->buildRpcResponseCollection();
 
         return $rpcResponse;
     }

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]);
         }
     }

Doc Comments +3 added lines

@@ -32,6 +32,9 @@
     }
 
 
+    /**
+     * @param string $name
+     */
     public function get($name)
     {
         if (isset($this->methods[$name])) {

Routing/Method.php

Indentation +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
     public function serialize()
     {
         return serialize([
-           'id' => $this->id,
+            'id' => $this->id,
             'name' => $this->name,
             'params' => $this->params,
             'defaults' => $this->defaults,

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'];
         }
     }
 

Doc Comments +9 added lines

@@ -125,6 +125,9 @@ 
         return $this;
     }
 
+    /**
+     * @param string $name
+     */
     public function getOption($name)
     {
         if (isset($this->options[$name])) {
@@ -161,6 +164,9 @@ 
         return $this;
     }
 
+    /**
+     * @param string $name
+     */
     public function getDefault($name)
     {
         if (isset($this->defaults[$name])) {
@@ -175,6 +181,9 @@ 
         return array_key_exists($name, $this->defaults);
     }
 
+    /**
+     * @param string $name
+     */
     public function setDefault($name, $default)
     {
         $this->defaults[$name] = $default;

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(

Doc Comments +9 added lines

@@ -19,6 +19,9 @@ 
     protected $options = [];
     private $configCacheFactory;
 
+    /**
+     * @param string $resource
+     */
     public function __construct(ContainerInterface $loader, $resource, array $options = [])
     {
         if (is_array($resource)) {
@@ -57,6 +60,9 @@ 
         }
     }
 
+    /**
+     * @param string $key
+     */
     public function setOption($key, $value)
     {
         if (!array_key_exists($key, $this->options)) {
@@ -66,6 +72,9 @@ 
         $this->options[$key] = $value;
     }
 
+    /**
+     * @param string $key
+     */
     public function getOption($key)
     {
         if (!array_key_exists($key, $this->options)) {