add support of enqueue simple client.

Author: makasim

Command/ConsumeMessagesCommand.php

@@ -0,0 +1,17 @@
+<?php
+namespace Enqueue\LaravelQueue\Command;
+
+use Enqueue\SimpleClient\SimpleClient;
+
+class ConsumeMessagesCommand extends \Enqueue\Symfony\Client\ConsumeMessagesCommand
+{
+    public function __construct(SimpleClient $client)
+    {
+        parent::__construct(
+            $client->getQueueConsumer(),
+            $client->getDelegateProcessor(),
+            $client->getQueueMetaRegistry(),
+            $client->getDriver()
+        );
+    }
+}

Command/ProduceMessageCommand.php

@@ -0,0 +1,12 @@
+<?php
+namespace Enqueue\LaravelQueue\Command;
+
+use Enqueue\SimpleClient\SimpleClient;
+
+class ProduceMessageCommand extends \Enqueue\Symfony\Client\ProduceMessageCommand
+{
+    public function __construct(SimpleClient $client)
+    {
+        parent::__construct($client->getProducer());
+    }
+}

Command/QueuesCommand.php

@@ -0,0 +1,12 @@
+<?php
+namespace Enqueue\LaravelQueue\Command;
+
+use Enqueue\SimpleClient\SimpleClient;
+
+class QueuesCommand extends \Enqueue\Symfony\Client\Meta\QueuesCommand
+{
+    public function __construct(SimpleClient $client)
+    {
+        parent::__construct($client->getQueueMetaRegistry());
+    }
+}

Command/SetupBrokerCommand.php

@@ -0,0 +1,13 @@
+<?php
+namespace Enqueue\LaravelQueue\Command;
+
+
+use Enqueue\SimpleClient\SimpleClient;
+
+class SetupBrokerCommand extends \Enqueue\Symfony\Client\SetupBrokerCommand
+{
+    public function __construct(SimpleClient $client)
+    {
+        parent::__construct($client->getDriver());
+    }
+}

Command/TopicsCommand.php

@@ -0,0 +1,12 @@
+<?php
+namespace Enqueue\LaravelQueue\Command;
+
+use Enqueue\SimpleClient\SimpleClient;
+
+class TopicsCommand extends \Enqueue\Symfony\Client\Meta\TopicsCommand
+{
+    public function __construct(SimpleClient $client)
+    {
+        parent::__construct($client->getTopicMetaRegistry());
+    }
+}

EnqueueServiceProvider.php

@@ -2,6 +2,12 @@
 
 namespace Enqueue\LaravelQueue;
 
+use Enqueue\LaravelQueue\Command\ConsumeMessagesCommand;
+use Enqueue\LaravelQueue\Command\ProduceMessageCommand;
+use Enqueue\LaravelQueue\Command\QueuesCommand;
+use Enqueue\LaravelQueue\Command\SetupBrokerCommand;
+use Enqueue\LaravelQueue\Command\TopicsCommand;
+use Enqueue\SimpleClient\SimpleClient;
 use Illuminate\Queue\QueueManager;
 use Illuminate\Support\ServiceProvider;
 
@@ -12,18 +18,53 @@ class EnqueueServiceProvider extends ServiceProvider
      */
     public function boot()
     {
-        /** @var QueueManager $manager */
-        $manager = $this->app['queue'];
-
-        $manager->addConnector('interop', function () {
-            return new Connector();
-        });
+        $this->bootInteropQueueDriver();
     }
 
     /**
      * {@inheritdoc}
      */
     public function register()
     {
+        $this->registerClient();
+    }
+
+    private function registerClient()
+    {
+        if (false == $this->app['config']->has('enqueue.client')) {
+            return;
+        }
+
+        if (false == class_exists(SimpleClient::class)) {
+            throw new \LogicException('The enqueue/simple-client package is not installed');
+        }
+
+        $this->app->singleton(SimpleClient::class, function() {
+            /** @var \Illuminate\Config\Repository $config */
+            $config = $this->app['config'];
+
+            var_dump($config->get('enqueue.client'));
+            return new SimpleClient($config->get('enqueue.client'));
+        });
+
+        if ($this->app->runningInConsole()) {
+            $this->commands([
+                SetupBrokerCommand::class,
+                ProduceMessageCommand::class,
+                QueuesCommand::class,
+                TopicsCommand::class,
+                ConsumeMessagesCommand::class,
+            ]);
+        }
+    }
+
+    private function bootInteropQueueDriver()
+    {
+        /** @var QueueManager $manager */
+        $manager = $this->app['queue'];
+
+        $manager->addConnector('interop', function () {
+            return new Connector();
+        });
     }
 }

composer.json

@@ -27,6 +27,9 @@
             "/Tests/"
         ]
     },
+    "suggest": {
+        "enqueue/simple-client": "If you want to use enqueue client and cli commands"
+    },
     "extra": {
         "branch-alias": {
             "dev-master": "0.6.x-dev"