NSQjs Promise
Javescript nsq client base on nsqjs
with promise.
一个基于 nsqjs
库进行 promise 化封装的 nsq 客户端.
Installation
npm install nsqjs-promise
Usage
const NSQ = ;const autoFinish = ; { console; try await ; console; catch e console; throw e; } { // $ nsqlookupd // $ nsqd --lookupd-tcp-address=127.0.0.1:4160 // $ nsqadmin --lookupd-http-address=127.0.0.1:4161 // ------------------------------ Reader ---------------------------------- const reader = topic: 'sample_topic' channel: 'sample_channel' lookupdHTTPAddresses: '127.0.0.1:4161' nsqdTCPAddresses: '127.0.0.1:4150' ; reader; reader; readerall { return id: messageid data: message ; } { console; } ; await reader; // ------------------------------ Writer ---------------------------------- const writer = host: '127.0.0.1' port: 4150 ; await writer; await writer; await writer;} ;/*handle message 0b1666645e9b8000 ...0b1666645e9b8000 { fitst: 'one' }handle message 0b1666645e9b8000 succeedhandle message 0b166664605b8000 ...0b166664605b8000 { second: 'two' }handle message 0b166664605b8000 succeed */