data-dog/php-nsq

NSQ publisher for PHP

0.2.3 2014-09-01 12:05 UTC

This package is not auto-updated.

Last update: 2024-04-09 01:13:25 UTC


README

This library ONLY publishes messages to NSQ nodes. Requires standard php socket extension.

Install

Add to composer.json:

{
    "require": {
        "data-dog/php-nsq": "~0.2.0"
    }
}

Usage example

<?php

include __DIR__ . '/vendor/autoload.php';

use Nsq\NsqPool;
use Nsq\Socket\PhpSocket;
use Nsq\Message\JsonMessage;

$nsq = new NsqPool(
    new PhpSocket('127.0.0.1', 4150),
    new PhpSocket('127.0.0.1', 4170)
);

$nsq->publish('my_topic', new JsonMessage(['message' => 'data']));

Run tests

composer install
./bin/phpspec run