nsqjs-extra

Extra NodeJS client for the nsq client protocol, supporting async/await function.

About

nsqjs-extra

Extra NodeJS client for the nsq client protocol.
Adding:

- reader.connectSync
- reader.closeSync
- writer.connectSync
- writer.publishSync
- writer.deferPublishSync
- writer.closeSync

Install

``bash
npm add nsqjs-extra
`

Usage

`js
const { Reader, Writer } = require('nsqjs-extra')

const reader = new Reader('topic', 'default', { nsqdTCPAddresses: ['127.0.0.1:4150'] })
await reader.connectSync()
// do something
await reader.closeSync()

const writer = new Writer('127.0.0.1', '4150')
await writer.connectSync()
await writer.publishSync('topic', 'message')
await writer.deferPublishSync('topic', ['message'], 1000)
await writer.closeSync()
``

Contributing

Please consult CONTRIBUTING for guidelines on contributing to this project.

Author

nsqjs-extra © Hoang Dinh, Released under the MIT License.