README

Allows receiving custom messages from Amazon SQS.

Note that message does not need to be in JSON either. Handler (by default JoblessHandler) will be called with raw message string. You can then do whatever you want with the string.

Why?

Because Laravel by default only allows receiving job messages from SQS. Those job messages have very strict form. Any incoming SQS message not following the form will be released back to the queue.

This component allows arbitrary SQS messages to be received and handled by the Laravel.

Install

Step 1:

composer require adalessa/laravel-sqs-jobless

Note! If you get installation error because of minimum-stability issue, you need to add key-pair "minimum-stability": "dev" to your composer.json file.

Step 2:

Add Service Provider

'providers' => [
    // ...
    'Adalessa\SQSJobless\JoblessSQSServiceProvider',
];

Usage

Usage needs four steps:

Make sure service provider is added.
Create new record to config/queue.php
Create App/Jobs/YourJob class
Change queue driver to sqs-jobless
Start the queue.

1.

'providers' => [
    // ...
    'Adalessa\SQSJobless\JoblessSQSServiceProvider',
];

2.

// app.config.queue.php

'sqs-jobless' => [
    'driver' => 'sqs-jobless',
    'key' => '1122334455667788XX',
    'secret' => 'xxxxxxxxxxxxxxxxxxxxxxxxxx',
    'prefix' => 'https://sqs.eu-central-1.amazonaws.com/11223344556677',
    'queue' => 'msgs',
    'region' => 'eu-central-1',
    'class' => \App\Jobs\YourJob::class,
],

3.

// App\Jobs\YourJob.php

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;

class YourJob implements ShouldQueue
{
    use InteractsWithQueue, Queueable, SerializesModels;

    protected $passedInData;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct($data)
    {
        // $data is STRING containing the msg content from SQS
        $this->passedInData = $data;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
       \Log::info($this->passedInData);
       // Check laravel.log, it should now contain msg string.
    }
}

4.

// .env

QUEUE_DRIVER=sqs-jobless

5.

On command line:

php artisan queue:work

Custom msg handler

You can easily define your own handler class for messages. You can do this on config.sqs-jobless.php.

Note that only one handler can be defined at a time.

adalessa / laravel-sqs-jobless

Maintainers

Details