joaoluizjoaquim/laravel-nsq

Nsq driver for Laravel Queue

Maintainers

Details

github.com/joaoluizjoaquim/laravel-nsq

Source

Installs: 2 090

Dependents: 0

Suggesters: 0

Security: 0

Stars: 1

Watchers: 1

Forks: 4

8.0.14 2021-03-12 12:40 UTC

Requires

MIT b5eeeb2c70ddecd6f12b7d27ab24308c0ab59b5c

  • João Joaquim

This package is auto-updated.

Last update: 2025-03-12 21:06:46 UTC

README

NSQ client for laravel

Requirements

Dependency Requirement
PHP >= 7.2.0

Installation

composer require jiyis/laravel-nsq

Usage

Set env

# for publish
NSQSD_URL=127.0.0.1:4150 
# for subscribe
NSQLOOKUP_URL=127.0.0.1:4161 

# If it is multiple, please separate them with ","
NSQSD_URL=127.0.0.1:4150,127.0.0.1:4250

Create Job

php artisan make:job NsqTestJob

you need set two property. public $topic; public $channel;

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