Команды.

Author: ProklUng

README.md

@@ -3,13 +3,15 @@
 ## Зачем?
 
 Оригинальный модуль заточен под битриксовый сервис-локатор, а он встречается только на версиях главного модуля больше,
-чем `20.5.400`. На моих проектах такой свежести нет, а функционал интересный. 
+чем `20.5.400`. На моих проектах такой свежести нет, а функционал интересный и полезный. 
 
 ## Отличия
 
 Выпилил (частично, пока не касается команд) битриксовый сервис-локатор в пользу отдельного симфонического контейнера.
 
-Исправил некоторое количество ошибок. 
+Исправил некоторое количество ошибок.
+
+Добавил к командам префикс `bitrix-`, чтобы избежать конфликта с командами оригинального бандла `RabbitMqBundle`. 
 
 # Оригинальное readme.MD с некоторыми корректировками
 
@@ -161,11 +163,11 @@ class UploadPictureConsumer implements ConsumerInterface
 Если у вас установлен модуль [yngc0der.cli](https://github.com/yngc0der/bitrix-cli), вам будут доступны некоторые
 команды, которые упрощают работу:
 
-* `rabbitmq:consumer`        Executes a consumer
-* `rabbitmq:delete`          Delete a consumer's queue
-* `rabbitmq:purge`           Purge a consumer's queue
-* `rabbitmq:setup-fabric`    Sets up the Rabbit MQ fabric
-* `rabbitmq:stdin-producer`  Executes a producer that reads data from STDIN
+* `bitrix-rabbitmq:consumer`        Executes a consumer
+* `bitrix-rabbitmq:delete`          Delete a consumer's queue
+* `bitrix-rabbitmq:purge`           Purge a consumer's queue
+* `bitrix-abbitmq:setup-fabric`     Sets up the Rabbit MQ fabric
+* `bitrix-rabbitmq:stdin-producer`  Executes a producer that reads data from STDIN
 
 ## Адаптировано к Bitrix
 - [x] Connection (Stream, Socket, Lazy, LazySocket)

lib/Command/ConsumerCommand.php

@@ -8,7 +8,7 @@ protected function configure()
     {
         parent::configure();
         $this->setDescription('Executes a consumer');
-        $this->setName('rabbitmq:consumer');
+        $this->setName('bitrix-rabbitmq:consumer');
     }
 
     protected function getConsumerService()

lib/Command/DeleteCommand.php

@@ -19,7 +19,7 @@ protected function configure()
              ->setDescription('Delete a consumer\'s queue')
              ->addOption('no-confirmation', null, InputOption::VALUE_NONE, 'Whether it must be confirmed before deleting');
 
-        $this->setName('rabbitmq:delete');
+        $this->setName('bitrix-rabbitmq:delete');
     }
 
     /**

lib/Command/PurgeConsumerCommand.php

@@ -19,7 +19,7 @@ protected function configure()
              ->setDescription('Purge a consumer\'s queue')
              ->addOption('no-confirmation', null, InputOption::VALUE_NONE, 'Whether it must be confirmed before purging');
 
-        $this->setName('rabbitmq:purge');
+        $this->setName('bitrix-rabbitmq:purge');
     }
 
     /**

lib/Command/SetupFabricCommand.php

@@ -12,7 +12,7 @@ class SetupFabricCommand extends BaseRabbitMqCommand
     protected function configure()
     {
         $this
-            ->setName('rabbitmq:setup-fabric')
+            ->setName('bitrix-rabbitmq:setup-fabric')
             ->setDescription('Sets up the Rabbit MQ fabric')
             ->addOption('debug', 'd', InputOption::VALUE_NONE, 'Enable Debugging')
         ;

lib/Command/StdInProducerCommand.php

@@ -17,7 +17,7 @@ protected function configure()
         parent::configure();
 
         $this
-            ->setName('rabbitmq:stdin-producer')
+            ->setName('bitrix-rabbitmq:stdin-producer')
             ->addArgument('name', InputArgument::REQUIRED, 'Producer Name')
             ->setDescription('Executes a producer that reads data from STDIN')
             ->addOption('route', 'r', InputOption::VALUE_OPTIONAL, 'Routing Key', '')

lib/Integration/CLI/Commands.php

@@ -7,8 +7,8 @@
 
 use Bitrix\Main\Event;
 use Bitrix\Main\EventResult;
-use Bitrix\Main\DI\ServiceLocator;
 use Proklung\RabbitMq\Command;
+use Proklung\RabbitMq\Integration\DI\Services;
 
 /**
  * Class Commands
@@ -18,7 +18,7 @@ class Commands
 {
     public static function onCommandsLoad(Event $event)
     {
-        $container = ServiceLocator::getInstance();
+        $container = Services::getInstance();
 
         $commands = [
             new Command\ConsumerCommand(),