Refactor commands

Author: ProklUng

composer.json

@@ -36,7 +36,7 @@
     "composer/installers": "~1",
     "php-amqplib/php-amqplib": "^2.12.1 || ^3",
     "psr/log": "^1.1.3",
-    "proklung/bitrix-containerable-boilerplate": "^1.0",
+    "proklung/bitrix-containerable-boilerplate": "^1.1",
     "proklung/bitrix.module.boilerplate": "^1.0",
     "ext-json": "*"
   },

lib/Command/ConsumerCommand.php

@@ -2,6 +2,10 @@
 
 namespace Proklung\RabbitMq\Command;
 
+/**
+ * Class ConsumerCommand
+ * @package Proklung\RabbitMq\Command
+ */
 class ConsumerCommand extends BaseConsumerCommand
 {
     protected function configure()

lib/Command/DeleteCommand.php

@@ -26,7 +26,7 @@ protected function configure()
      * @param InputInterface $input
      * @param OutputInterface $output
      *
-     * @return void
+     * @return integer
      */
     protected function execute(InputInterface $input, OutputInterface $output)
     {
@@ -44,12 +44,14 @@ protected function execute(InputInterface $input, OutputInterface $output)
             if (!$this->getHelper('question')->ask($input, $output, $question)) {
                 $output->writeln('<error>Deletion cancelled!</error>');
 
-                return;
+                return 1;
             }
         }
 
         $this->consumer = $this->getContainer()
             ->get(sprintf($this->getConsumerService(), $input->getArgument('name')));
         $this->consumer->delete();
+
+        return 0;
     }
 }

lib/Command/PurgeConsumerCommand.php

@@ -26,7 +26,7 @@ protected function configure()
      * @param InputInterface $input
      * @param OutputInterface $output
      *
-     * @return void
+     * @return integer
      */
     protected function execute(InputInterface $input, OutputInterface $output)
     {
@@ -44,12 +44,14 @@ protected function execute(InputInterface $input, OutputInterface $output)
             if (!$this->getHelper('question')->ask($input, $output, $question)) {
                 $output->writeln('<error>Purging cancelled!</error>');
 
-                return;
+                return 1;
             }
         }
 
         $this->consumer = $this->getContainer()
             ->get(sprintf($this->getConsumerService(), $input->getArgument('name')));
         $this->consumer->purge($input->getArgument('name'));
+
+        return 0;
     }
 }

lib/Command/SetupFabricCommand.php

@@ -9,6 +9,9 @@
 
 class SetupFabricCommand extends BaseRabbitMqCommand
 {
+    /**
+     * @inheritdoc
+     */
     protected function configure()
     {
         $this
@@ -18,6 +21,9 @@ protected function configure()
         ;
     }
 
+    /**
+     * @inheritdoc
+     */
     protected function execute(InputInterface $input, OutputInterface $output)
     {
         if (defined('AMQP_DEBUG') === false) {
@@ -37,5 +43,6 @@ protected function execute(InputInterface $input, OutputInterface $output)
             }
         }
 
+        return 0;
     }
 }

lib/Command/StdInProducerCommand.php

@@ -7,6 +7,10 @@
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 
+/**
+ * Class StdInProducerCommand
+ * @package Proklung\RabbitMq\Command
+ */
 class StdInProducerCommand extends BaseRabbitMqCommand
 {
     const FORMAT_PHP = 'php';