This package has been deprecated

Author message:

migrate to @sigodenjs/dee-natstreaming

@sigodenjs/dee-natstream

Dee-Natstreaming 框架

Usage

1. dee 中添加配置项

services: {
    mq: {
        constructor: 'natstream',
        constructorArgs: {
            templatePath: require('./template.json'),
            handlers: require('./handlers')
        }
    }
}

2. 编写 template.json

{
  "client": {
    "clusterId": "test-cluster",
    "server": "nats://localhost:4222"
  },
  "producers": {
    "<name>": {
      // fastest-validator validate pubilsh msg
      "schema": {
        "id": { "type": "number", "positive": true, "integer": true },
      }
    }
  },
  "subscribers": {
    "<service.name>": {
      "group": true,
      "durable": true,
      "noAutoAck": true,
      "maxInFlight": 16384,
      "ackWait": 30
    }
  }
}

3. 编写 handlers

module.exports = {
      'mysrv.sayHello': function(ctx) {
          ctx.srvs
      }
}

4. 发送消息

srvs.mq.send('sayHello', { name: 'abc' }, function(err, cb) {

})
srvs.mq.send('sayHello', { name: 'abc' }).then(function(data) {

})