moolex/nsqclient

Maintainers

Details

github.com/moolex/nsqclient-php

Source

Issues

Installs: 26 379

Dependents: 1

Suggesters: 0

Security: 0

Stars: 21

Watchers: 3

Forks: 12

Open Issues: 3

0.1.1 2017-09-29 07:29 UTC

Requires

MIT 76a68f69e087f908880b2298b882ded2062fb83e

nsq

This package is auto-updated.

Last update: 2024-12-06 19:54:21 UTC

README

Yet another PHP client for NSQ

Installation (via composer)

composer require moolex/nsqclient dev-master

Usage

Publish

$topic = 'my_topic';
$endpoint = new \NSQClient\Access\Endpoint('http://127.0.0.1:4161');
$message = new \NSQClient\Message\Message('hello world');
$result = \NSQClient\Queue::publish($endpoint, $topic, $message);

Publish (deferred)

$topic = 'my_topic';
$endpoint = new \NSQClient\Access\Endpoint('http://127.0.0.1:4161');
$message = (new \NSQClient\Message\Message('hello world'))->deferred(5);
$result = \NSQClient\Queue::publish($endpoint, $topic, $message);

Publish (batch)

$topic = 'my_topic';
$endpoint = new \NSQClient\Access\Endpoint('http://127.0.0.1:4161');
$message = \NSQClient\Message\Bag::generate(['msg data 1', 'msg data 2']);
$result = \NSQClient\Queue::publish($endpoint, $topic, $message);

Subscribe

$topic = 'my_topic';
$channel = 'my_channel';
$endpoint = new \NSQClient\Access\Endpoint('http://127.0.0.1:4161');
\NSQClient\Queue::subscribe($endpoint, $topic, $channel, function (\NSQClient\Contract\Message $message) {
    echo 'GOT ', $message->id(), "\n";
    // make done
    $message->done();
    // make retry immediately
    // $message->retry();
    // make retry delayed in 10 seconds
    // $message->delay(10);
});