use simple commands.

Author: makasim

composer.json

@@ -7,16 +7,17 @@
     "require": {
         "php": ">=7.1",
         "illuminate/queue": "^5.6",
-        "queue-interop/amqp-interop": "0.8.x-dev",
-        "queue-interop/queue-interop": "0.7.x-dev",
-        "enqueue/enqueue": "0.9.x-dev",
-        "enqueue/dsn": "0.9.x-dev"
+        "queue-interop/amqp-interop": "^0.8",
+        "queue-interop/queue-interop": "^0.7|^0.8",
+        "enqueue/enqueue": "^0.9",
+        "enqueue/dsn": "^0.9",
+        "enqueue/simple-client": "^0.9.3"
     },
     "require-dev": {
         "phpunit/phpunit": "~5.5",
-        "enqueue/enqueue": "0.9.x-dev",
-        "enqueue/null": "0.9.x-dev",
-        "enqueue/test": "0.9.x-dev"
+        "enqueue/enqueue": "^0.9",
+        "enqueue/null": "^0.9@dev",
+        "enqueue/test": "^0.9@dev"
     },
     "autoload": {
         "psr-4": { "Enqueue\\LaravelQueue\\": "src/" },

src/Command/ConsumeCommand.php

@@ -1,19 +1,17 @@
 <?php
 namespace Enqueue\LaravelQueue\Command;
 
-use Enqueue\Container\Container;
 use Enqueue\SimpleClient\SimpleClient;
+use Enqueue\Symfony\Client\SimpleConsumeCommand;
 
-class ConsumeCommand extends \Enqueue\Symfony\Client\ConsumeCommand
+class ConsumeCommand extends SimpleConsumeCommand
 {
     public function __construct(SimpleClient $client)
     {
-        $container = new Container([
-            'queue_consumer' => $client->getQueueConsumer(),
-            'driver' => $client->getDriver(),
-            'processor' => $client->getDelegateProcessor()
-        ]);
-
-        parent::__construct($container, 'queue_consumer', 'driver', 'processor');
+        parent::__construct(
+            $client->getQueueConsumer(),
+            $client->getDriver(),
+            $client->getDelegateProcessor()
+        );
     }
 }

src/Command/ProduceCommand.php

@@ -1,17 +1,13 @@
 <?php
 namespace Enqueue\LaravelQueue\Command;
 
-use Enqueue\Container\Container;
 use Enqueue\SimpleClient\SimpleClient;
+use Enqueue\Symfony\Client\SimpleProduceCommand;
 
-class ProduceCommand extends \Enqueue\Symfony\Client\ProduceCommand
+class ProduceCommand extends SimpleProduceCommand
 {
     public function __construct(SimpleClient $client)
     {
-        $container = new Container([
-            'producer' => $client->getProducer(),
-        ]);
-
-        parent::__construct($container, 'producer');
+        parent::__construct($client->getProducer());
     }
 }

src/Command/RoutesCommand.php

@@ -1,17 +1,13 @@
 <?php
 namespace Enqueue\LaravelQueue\Command;
 
-use Enqueue\Container\Container;
 use Enqueue\SimpleClient\SimpleClient;
+use Enqueue\Symfony\Client\SimpleRoutesCommand;
 
-class RoutesCommand extends \Enqueue\Symfony\Client\RoutesCommand
+class RoutesCommand extends SimpleRoutesCommand
 {
     public function __construct(SimpleClient $client)
     {
-        $container = new Container([
-            'driver' => $client->getDriver(),
-        ]);
-
-        parent::__construct($container, 'driver');
+        parent::__construct($client->getDriver());
     }
 }

src/Command/SetupBrokerCommand.php

@@ -1,18 +1,13 @@
 <?php
 namespace Enqueue\LaravelQueue\Command;
 
-
-use Enqueue\Container\Container;
 use Enqueue\SimpleClient\SimpleClient;
+use Enqueue\Symfony\Client\SimpleSetupBrokerCommand;
 
-class SetupBrokerCommand extends \Enqueue\Symfony\Client\SetupBrokerCommand
+class SetupBrokerCommand extends SimpleSetupBrokerCommand
 {
     public function __construct(SimpleClient $client)
     {
-        $container = new Container([
-            'driver' => $client->getDriver(),
-        ]);
-
-        parent::__construct($container, 'driver');
+        parent::__construct($client->getDriver());
     }
 }