jiyis/laravel-nsq

Nsq driver for Laravel Queue

Laravel Nsq Client

NSQ client for laravel, _(*1)

Requirements

Installation

pecl install swoole

``` composer require jiyis/laravel-nsq, <sub>(*2)</sub>

## Usage
#### Set env

NSQSD_URL=127.0.0.1:4150 NSQLOOKUP_URL=127.0.0.1:4161, <sub>(*3)</sub>

If it is multiple, please separate them with ","

NSQSD_URL=127.0.0.1:4150,127.0.0.1:4250, <sub>(*4)</sub>

#### Create Job

php artisan make:job NsqTestJob, <sub>(*5)</sub>

you need set two property. `public $topic;` `public $channel;`
```php
class NsqTestJob  implements ShouldQueue
{

    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public $topic = 'test';

    public $channel = 'web';

    public function handle()
    {
        $client = $this->job->getCurrentClient();
        $payload = json_decode($this->job->getMessage(), true);
        ...
    }
}

Publish

// the data you want to be publish 
$str = [
    'message' => 'this is a message',
    'user_id' => 1
];
// not supported dispatch
Queue::connection('nsq')->push(new NsqTestJob, $str);

Subscribe

php artisan queue:work nsq --sleep=3 --tries=3 --timeout=500  --job=App\\Jobs\\NsqTestJob