FD3-223 AMQP Consumer

Services/CommandConsumer.php

@@ -9,7 +9,7 @@ use Symfony\Component\DependencyInjection\ContainerInterface;
 use Symfony\Component\Console\Input\ArrayInput;
 use Symfony\Component\Console\Output\BufferedOutput;
 
-class CommandConsumer
+class CommandConsumer implements ConsumerInterface
 {
 
     /**
@@ -48,9 +48,7 @@ class CommandConsumer
             foreach ($args as $arg) {
                 $pieces = explode(':', $arg);
                 if (isset($pieces[0]) && isset($pieces[1])) {
-                    $input["--{$pieces[0]}"] = $pieces[1];
-                } elseif (isset($pieces[0])) {
-                    $input[] = $pieces[0];
+                    $input[$pieces[0]] = $pieces[1];
                 }
             }