NSQ client written in rust
Sponsored by
A Actix based client implementation for the NSQ realtime message processing system.
Nsq-client it's designed to support by default multiple Readers for Multiple Connections, readers are routed per single connection by a round robin algorithm.
Usage
To use nsq-client, add this to your Cargo.toml:
[]
= "0.7"
= "0.1.10"
Create your first consumer
In order to use nsq-client you first need to create a Reader actor which implement Handler for the type of messages you want to receive from the connections and then subscribe it to the connections to be able to receive the type of messages you've selected.
Available messages are:
Simple Consumer (SUB)
extern crate nsqueue;
extern crate actix;
use Arc;
use *;
use ;
launch nsqd
launch the reader
launch the producer
Examples
ToDo
- Discovery
- TLS
- Snappy
- First-ready-first-served readers routing algorithm.
License
Licensed under
- MIT license (see LICENSE or http://opensource.org/licenses/MIT)