Improved queue name

Author: palPalani

README.md

@@ -15,30 +15,112 @@ You can install the package via composer:
 composer require palpalani/laravel-sqs-queue-json-reader
 ```
 
-You can publish and run the migrations with:
-
-```bash
-php artisan vendor:publish --provider="Palpalani\SqsQueueReader\SqsQueueReaderServiceProvider" --tag="migrations"
-php artisan migrate
-```
-
 You can publish the config file with:
 ```bash
-php artisan vendor:publish --provider="Palpalani\SqsQueueReader\SqsQueueReaderServiceProvider" --tag="config"
+php artisan vendor:publish --provider="palPalani\SqsQueueReader\SqsQueueReaderServiceProvider" --tag="config"
 ```
 
 This is the contents of the published config file:
 
 ```php
 return [
+
+    /**
+     * Separate queue handle with corresponding queue name as key.
+     */
+    'handlers' => [
+        //'stripe-webhooks' => App\Jobs\SqsHandler::class,
+    ],
+
+    'default-handler' => App\Jobs\SqsHandler::class
 ];
 ```
 
-## Usage
+If queue is not found in 'handlers' array, SQS payload is passed to default handler.
+
+Add sqs-json connection to your config/queue.php, eg:
+
+```php
+    [
+        // Add connection
+        'sqs-json' => [
+            'driver' => 'sqs-json',
+            'key'    => env('AWS_KEY', ''),
+            'secret' => env('AWS_SECRET', ''),
+            'prefix' => 'https://sqs.us-west-2.amazonaws.com/3242342351/',
+            'queue'  => 'stripe-webhooks',
+            'region' => 'ap-southeast-2',
+        ],
+    ]
+```
+
+In your .env file, choose sqs-plain as your new default queue driver:
+
+```
+QUEUE_DRIVER=sqs-json
+```
+
+Dispatching to SQS
+
+If you plan to push plain messages from Laravel or Lumen, you can rely on DispatcherJob:
+
+```php
+use palPalani\SqsQueueReader\Jobs\DispatcherJob;
+
+class ExampleController extends Controller
+{
+    public function index()
+    {
+        // Create a PHP object
+        $object = [
+            'music' => 'Sample message',
+            'time' => time()
+        ];
+
+        // Pass it to dispatcher job
+        $job = new DispatcherJob($object);
+
+        // Dispatch the job as you normally would
+        // By default, your data will be encapsulated in 'data' and 'job' field will be added
+        $this->dispatch($job);
+
+        // If you wish to submit a true plain JSON, add setPlain()
+        $this->dispatch($job->setPlain());
+    }
+}
+```
+This will push the following JSON object to SQS:
+
+```json
+{"job":"App\\Jobs\\SqsHandler@handle","data":{"music":"Sample message","time":1464411642}}
+```
+
+'job' field is not used, actually. It's just kept for compatibility.
+
+Receiving from SQS
+If a third-party application is creating custom-format JSON messages, just add a 
+handler in the config file and implement a handler class as follows:
 
 ```php
-$laravel-sqs-queue-json-reader = new Palpalani\SqsQueueReader();
-echo $laravel-sqs-queue-json-reader->echoPhrase('Hello, Palpalani!');
+use Illuminate\Contracts\Queue\Job as LaravelJob;
+
+class HandlerJob extends Job
+{
+    protected $data;
+
+    /**
+     * @param LaravelJob $job
+     * @param array $data
+     */
+    public function handle(LaravelJob $job, array $data)
+    {
+        // This is incoming JSON payload, already decoded to an array
+        var_dump($data);
+
+        // Raw JSON payload from SQS, if necessary
+        var_dump($job->getRawBody());
+    }
+}
 ```
 
 ## Testing

phpunit.xml.dist

@@ -11,7 +11,7 @@
          verbose="true"
 >
     <testsuites>
-        <testsuite name="Palpalani Test Suite">
+        <testsuite name="palPalani Test Suite">
             <directory>tests</directory>
         </testsuite>
     </testsuites>

src/Jobs/DispatcherJob.php

@@ -39,7 +39,7 @@ public function getPayload()
     {
         if (! $this->isPlain()) {
             return [
-                'job' => app('config')->get('sqs-plain.default-handler'),
+                'job' => app('config')->get('sqs-queue-reader.default-handler'),
                 'data' => $this->data,
             ];
         }

src/SqsQueueReaderServiceProvider.php

@@ -27,7 +27,7 @@ public function register()
         $this->mergeConfigFrom(__DIR__ . '/../config/sqs-queue-reader.php', 'laravel-sqs-queue-json-reader');
 
         $this->app->booted(function () {
-            $this->app['queue']->extend('sqs-plain', static function () {
+            $this->app['queue']->extend('sqs-json', static function () {
                 return new Connector();
             });
         });

tests/ExampleTest.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Palpalani\SqsQueueReader\Tests;
+namespace palPalani\SqsQueueReader\Tests;
 
 class ExampleTest extends TestCase
 {

tests/TestCase.php

@@ -1,9 +1,9 @@
 <?php
 
-namespace Palpalani\SqsQueueReader\Tests;
+namespace palPalani\SqsQueueReader\Tests;
 
 use Orchestra\Testbench\TestCase as Orchestra;
-use Palpalani\SqsQueueReader\SqsQueueReaderServiceProvider;
+use palPalani\SqsQueueReader\SqsQueueReaderServiceProvider;
 
 class TestCase extends Orchestra
 {