Merge pull request #2 from qpautrat/delete_queue_cli

Delete queue cli
Evaneos · Apr 18, 2017 · c8db720 · c8db720
2 parents fbe3576 + c37b1af
commit c8db720
Show file tree

Hide file tree

Showing 3 changed files with 48 additions and 5 deletions.
diff --git a/src/DependencyInjection/Configuration.php b/src/DependencyInjection/Configuration.php
@@ -29,7 +29,9 @@ public function getConfigTreeBuilder()
             ->fixXmlConfig('publisher')
             ->fixXmlConfig('worker')
             ->children()
+                ->scalarNode('default_driver')->end()
                 ->arrayNode('drivers')
+                    ->requiresAtLeastOneElement()
                     ->useAttributeAsKey('name')
                     ->prototype('array')
                         ->children()

diff --git a/src/DependencyInjection/EvaneosBurrowExtension.php b/src/DependencyInjection/EvaneosBurrowExtension.php
@@ -12,6 +12,11 @@
 use Symfony\Component\DependencyInjection\Definition;
 use Evaneos\BurrowBundle\WorkerFactory;
 use Evaneos\Daemon\CLI\DaemonWorkerCommand;
+use Burrow\CLI\DeleteExchangeCommand;
+use Burrow\CLI\DeclareExchangeCommand;
+use Burrow\CLI\DeleteQueueCommand;
+use Burrow\CLI\DeclareQueueCommand;
+use Burrow\CLI\BindCommand;
 
 /**
  * This is the class that loads and manages your bundle configuration.
@@ -28,7 +33,12 @@ public function load(array $configs, ContainerBuilder $container)
         $configuration = new Configuration();
         $config = $this->processConfiguration($configuration, $configs);
 
-        // var_dump($config); die;
+        if (!isset($config['default_driver'])) {
+            $keys = array_keys($config['drivers']);
+            $config['default_driver'] = reset($keys);
+        }
+
+        $container->setAlias('evaneos_burrow.default_driver', sprintf('evaneos_burrow.driver.%s', $config['default_driver']));
 
         foreach ($config['drivers'] as $name => $driver) {
             $container
@@ -60,5 +70,36 @@ public function load(array $configs, ContainerBuilder $container)
                 ->addArgument(sprintf('burrow:consume:%s', $name))
                 ->addTag('console.command');
         }
+
+        $this->loadBurrowCommands($container);
+    }
+
+    private function loadBurrowCommands(ContainerBuilder $container)
+    {
+        $container
+            ->register('evaneos_burrow.command.declare_queue', DeclareQueueCommand::class)
+            ->addArgument(new Reference('evaneos_burrow.default_driver'))
+            ->addMethodCall('setName', ['burrow:command:declare_queue'])
+            ->addTag('console.command');
+        $container
+            ->register('evaneos_burrow.command.delete_queue', DeleteQueueCommand::class)
+            ->addArgument(new Reference('evaneos_burrow.default_driver'))
+            ->addMethodCall('setName', ['burrow:command:delete_queue'])
+            ->addTag('console.command');
+        $container
+            ->register('evaneos_burrow.command.declare_exchange', DeclareExchangeCommand::class)
+            ->addArgument(new Reference('evaneos_burrow.default_driver'))
+            ->addMethodCall('setName', ['burrow:command:declare_exchange'])
+            ->addTag('console.command');
+        $container
+            ->register('evaneos_burrow.command.delete_exchange', DeleteExchangeCommand::class)
+            ->addArgument(new Reference('evaneos_burrow.default_driver'))
+            ->addMethodCall('setName', ['burrow:command:delete_exchange'])
+            ->addTag('console.command');
+        $container
+            ->register('evaneos_burrow.command.bind', BindCommand::class)
+            ->addArgument(new Reference('evaneos_burrow.default_driver'))
+            ->addMethodCall('setName', ['burrow:command:bind'])
+            ->addTag('console.command');
     }
 }
diff --git a/tests/app/config/config.yml b/tests/app/config/config.yml
@@ -3,10 +3,10 @@ framework:
 evaneos_burrow:
     drivers:
         default:
-            host: rabbitmq_host
-            port: rabbitmq_port
-            user: rabbitmq_user
-            pwd: rabbitmq_pwd
+            host: localhost
+            port: 5672
+            user: guest
+            pwd: guest
     publishers:
         default:
             driver: default