etna-alternance / composer-rabbitmq-service-provider

src/Consumer.php

Doc Comments +3 added lines

@@ -54,6 +54,9 @@
         $this->consumer->consume($this->amount);
     }
 
+    /**
+     * @param InputInterface $input
+     */
     protected function getConsumerInstance($input)
     {
         $app = $this->getSilexApplication();

Unused Use Statements +1 added lines, -1 removed lines

@@ -2,11 +2,11 @@
 
 namespace ETNA\Silex\Provider\RabbitMQ;
 
+use ETNA\Silex\Provider\Console\SilexCommand;
 use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Output\OutputInterface;
-use ETNA\Silex\Provider\Console\SilexCommand;
 
 class Consumer extends SilexCommand
 {

src/RabbitServiceProvider.php

Doc Comments +21 added lines

@@ -52,6 +52,9 @@ 
         return $app['rabbit.connection'][$connection_name];
     }
 
+    /**
+     * @param Container $app
+     */
     private function loadConnections($app)
     {
         $app['rabbit.connection'] = function ($app) {
@@ -82,6 +85,9 @@ 
         };
     }
 
+    /**
+     * @param Container $app
+     */
     private function loadProducers($app)
     {
         $app['rabbit.producer'] = function ($app) {
@@ -112,6 +118,9 @@ 
         };
     }
 
+    /**
+     * @param Container $app
+     */
     private function loadConsumers($app)
     {
         $app['rabbit.consumer'] = function ($app) {
@@ -150,6 +159,9 @@ 
         };
     }
 
+    /**
+     * @param Container $app
+     */
     private function loadAnonymousConsumers($app)
     {
         $app['rabbit.anonymous_consumer'] = function ($app) {
@@ -171,6 +183,9 @@ 
         };
     }
 
+    /**
+     * @param Container $app
+     */
     private function loadMultipleConsumers($app)
     {
         $app['rabbit.multiple_consumer'] = function ($app) {
@@ -209,6 +224,9 @@ 
 
     }
 
+    /**
+     * @param Container $app
+     */
     private function loadRpcClients($app)
     {
         $app['rabbit.rpc_client'] = function ($app) {
@@ -232,6 +250,9 @@ 
         };
     }
 
+    /**
+     * @param Container $app
+     */
     private function loadRpcServers($app)
     {
         $app['rabbit.rpc_server'] = function ($app) {

Unused Use Statements +4 added lines, -6 removed lines

@@ -2,18 +2,16 @@
 
 namespace ETNA\Silex\Provider\RabbitMQ;
 
-use Pimple\ServiceProviderInterface;
-use Pimple\Container;
-use Symfony\Component\Routing\Generator\UrlGenerator;
-use OldSound\RabbitMqBundle\RabbitMq\Producer;
-use OldSound\RabbitMqBundle\RabbitMq\Consumer;
 use OldSound\RabbitMqBundle\RabbitMq\AnonConsumer;
+use OldSound\RabbitMqBundle\RabbitMq\Consumer;
 use OldSound\RabbitMqBundle\RabbitMq\MultipleConsumer;
+use OldSound\RabbitMqBundle\RabbitMq\Producer;
 use OldSound\RabbitMqBundle\RabbitMq\RpcClient;
 use OldSound\RabbitMqBundle\RabbitMq\RpcServer;
 use PhpAmqpLib\Connection\AMQPConnection;
-use PhpAmqpLib\Connection\AMQPLazyConnection;
 use PhpAmqpLib\Connection\AMQPSSLConnection;
+use Pimple\Container;
+use Pimple\ServiceProviderInterface;
 
 /**
  * Code repris de fiunchinho/rabbitmq-service-provider en attendant la compatibilité