{"_id":"@agile-framework/agile-rocketmq","_rev":"1-555f79ac752b29a71b38e9d47cc137bc","name":"@agile-framework/agile-rocketmq","dist-tags":{"latest":"3.6.5"},"versions":{"3.6.5":{"name":"@agile-framework/agile-rocketmq","version":"3.6.5","description":"rocketmq nodejs client fork ali-ons","main":"lib/index.js","scripts":{"autod":"autod","pkgfiles":"egg-bin pkgfiles --check","lint":"eslint . --ext .js","test":"npm run lint && npm run test-local","test-local":"TEST_TIMEOUT=120000 egg-bin test","cov":"TEST_TIMEOUT=120000 egg-bin cov","ci":"npm run autod -- --check && npm run pkgfiles && npm run lint && npm run cov","contributors":"contributors -f plain -o AUTHORS"},"repository":{"type":"git","url":"git+https://github.com/iqinning/ali-ons.git"},"keywords":["ons","aliyun","ali-sdk"],"author":{"name":"qinning","email":"qinning.qn@gmail.com"},"license":"MIT","bugs":{"url":"https://github.com/iqinning/ali-ons"},"homepage":"https://github.com/iqinning/ali-ons","dependencies":{"JSON2":"^0.1.0","address":"^1.1.0","binary-search-insert":"^1.0.3","byte":"^2.0.0","bytes":"^3.1.0","debug":"^4.1.1","is-type-of":"^1.2.1","long":"^4.0.0","mkdirp":"^0.5.1","mz-modules":"^2.1.0","osenv":"^0.1.5","p-gather":"^1.0.2","sdk-base":"^3.6.0","tcp-base":"^3.1.0","utility":"^1.16.1"},"devDependencies":{"autod":"^3.1.0","contributors":"^0.5.1","egg-bin":"^4.13.0","eslint":"^5.16.0","eslint-config-egg":"^7.4.1","mm":"^2.5.0","urllib":"^2.34.0"},"engines":{"node":">= 8.0.0"},"contributors":[{"name":"GaoXiaochen","email":"gxcsoccer@users.noreply.github.com"},{"name":"宗羽","email":"xiaochen.gaoxc@alibaba-inc.com"}],"gitHead":"42a6822dffa488f36332141d4ddea324bfde0550","_id":"@agile-framework/agile-rocketmq@3.6.5","_npmVersion":"6.4.1","_nodeVersion":"8.12.0","_npmUser":{"name":"qinning","email":"qinning.qn@gmail.com"},"dist":{"integrity":"sha512-2BLGpue9BPguboYg2pANJFCR+TO0K/eNgfYD892JoggYZSNo45iiWBacGp/0fcmFXm3To6X61Fn+DldhYZWXVQ==","shasum":"f284487ce31ad8023a91ef026b5a122e08465b56","tarball":"https://registry.npmjs.org/@agile-framework/agile-rocketmq/-/agile-rocketmq-3.6.5.tgz","fileCount":40,"unpackedSize":154081,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJc/mymCRA9TVsSAnZWagAAt+IQAI4Uvpici2fdlBsTGQBH\ndxYDrr1gs17i3Lth6M/KKY1rT9ctEcKfpD/DdfaSYaICUzRrGOlXrD7kxLSU\nA9wF6jrbqmaozRUkUVafVjlFtRWygtsmafTYL/F342vhzKvCg50JqlrEUKOi\nzJlt2SXZmgkoAjEkFNEF3V0eAvbgVscOhxoVuU++azwM6o/6ECRnV3qX9unh\nn1sAJEInYQ6Ir1OlQCRVTQvWxRFk3vZofRGJ45A/AuojtabeJTgVhQrA7CxW\nGccY+73DNjBaCrxTMRgNLhnuUuS0w33BOnIzvD/kx36LICrUn5+Pbr74H38H\nC/FEWjN20psoHMZk+nNhmxeNIOLV1HrDiUjBhbL2adbYGjmN/ZTcmI3ZWtdH\nh47z7syZYuHQ1ZVrzV6a0r6HvVA9Mmw/hsiJ5aPAepUK5BwSwnOMyWHRsp98\nSlg3VTO4Eb/NmTY7nHDPkHg4FEUWwwD4ncd9E4n4Mi7LiC/n/PDEhulrOGzI\nLc4gH5NkcSUH7womhleh8o8d0IRmPh+b4alVOhExVNX3fSfOvVYWv6B2IUbh\nyTLYEa44Zrq5VYi0x/j/zC0of78x4z4AJO9sh6pRDx0cLYcHIAaz3TnOd+Rm\nCUGdfnv8eO8ttm/ZQshkxp4boCCr+3fqGCTf3PnIh2R9B1DSYqzA2Nkhqq7/\nwRaf\r\n=1zdV\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIHaGoCzeSniWW5sbpgEn+ARhq36Omy1ZuQct6vEQDJaEAiAB28b0MbZqra7lyRZ5FjRoTrqrfm5Qpkk3JtEwMFpLJg=="}]},"maintainers":[{"name":"qinning","email":"qinning.qn@gmail.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/agile-rocketmq_3.6.5_1560177830279_0.2677151804274811"},"_hasShrinkwrap":false}},"time":{"created":"2019-06-10T14:43:50.088Z","3.6.5":"2019-06-10T14:43:50.407Z","modified":"2022-04-04T11:57:23.204Z"},"maintainers":[{"name":"qinning","email":"qinning.qn@gmail.com"}],"description":"rocketmq nodejs client fork ali-ons","homepage":"https://github.com/iqinning/ali-ons","keywords":["ons","aliyun","ali-sdk"],"repository":{"type":"git","url":"git+https://github.com/iqinning/ali-ons.git"},"contributors":[{"name":"GaoXiaochen","email":"gxcsoccer@users.noreply.github.com"},{"name":"宗羽","email":"xiaochen.gaoxc@alibaba-inc.com"}],"author":{"name":"qinning","email":"qinning.qn@gmail.com"},"bugs":{"url":"https://github.com/iqinning/ali-ons"},"license":"MIT","readme":"ali-ons\n=======\n\n[![NPM version][npm-image]][npm-url]\n[![build status][travis-image]][travis-url]\n[![David deps][david-image]][david-url]\n\n[npm-image]: https://img.shields.io/npm/v/ali-ons.svg?style=flat-square\n[npm-url]: https://npmjs.org/package/ali-ons\n[travis-image]: https://img.shields.io/travis/ali-sdk/ali-ons.svg?style=flat-square\n[travis-url]: https://travis-ci.org/ali-sdk/ali-ons\n[david-image]: https://img.shields.io/david/ali-sdk/ali-ons.svg?style=flat-square\n[david-url]: https://david-dm.org/ali-sdk/ali-ons\n\nAliyun Open Notification Service Client (base on opensource project [RocketMQ](https://rocketmq.apache.org/))\n\nSub module of [ali-sdk](https://github.com/ali-sdk/ali-sdk).\n\n## Install\n\n```bash\nnpm install ali-ons --save\n```\n\n## Usage\n\nconsumer\n\n```js\n'use strict';\n\nconst httpclient = require('urllib');\nconst Consumer = require('ali-ons').Consumer;\nconst consumer = new Consumer({\n  httpclient,\n  accessKeyId: 'your-accessKeyId',\n  accessKeySecret: 'your-AccessKeySecret',\n  consumerGroup: 'your-consumer-group',\n  // namespace: '', // aliyun namespace support\n  // isBroadcast: true,\n});\n\nconsumer.subscribe(config.topic, '*', async msg => {\n  console.log(`receive message, msgId: ${msg.msgId}, body: ${msg.body.toString()}`)\n});\n\nconsumer.on('error', err => console.log(err));\n```\n\nproducer\n\n```js\n'use strict';\nconst httpclient = require('urllib');\nconst Producer = require('ali-ons').Producer;\nconst Message = require('ali-ons').Message;\n\nconst producer = new Producer({\n  httpclient,\n  accessKeyId: 'your-accessKeyId',\n  accessKeySecret: 'your-AccessKeySecret',\n  producerGroup: 'your-producer-group',\n  // namespace: '', // aliyun namespace support\n});\n\n(async () => {\n  const msg = new Message('your-topic', // topic\n    'TagA', // tag\n    'Hello ONS !!! ' // body\n  );\n\n  // set Message#keys\n  msg.keys = ['key1'];\n\n  // delay consume\n  // msg.setStartDeliverTime(Date.now() + 5000);\n\n  const sendResult = await producer.send(msg);\n  console.log(sendResult);\n})().catch(err => console.error(err))\n```\n\n## Secure Keys\n\nPlease contact to @gxcsoccer to give you accessKey\n\n- [ons secure data](https://sharelock.io/1/UM02CJiYyhXiZDOn1nhX0iqPqMIQtdwI_T5BY3F-tHs.d8-ycA/01veKH9kgAuFuKCqlVPzGsyPWJ8mQLaKPJjjcB9tpdbvi9L6XQ/IgqDvAdVDMzV9lK2gQzyAj7q-CNk8-1tWrLmdqMV0oJ5qgky40/HgpZyKKDfOGAcyqQ20RUdRgCLRWqF8LUUko0uDl_L-ATNOsi5z/W2bsvBc8tAoqSwNR7u2Sqe6XkNmD98s3UQOK-6T8--VwTbHzcG/dwkHwie3EkGB-TbiMnbRh7_5A-DaOTCtALP3xvl4G0XKxuOriC/2yfuPp7WRucTAoqx2STO5Hv3MZEhh3IXf7YiOQ8pWDDqjLuQSY/_irqzYyeseY9m106ksMUq3-yS_qkBRIuoyL-hHk9ZRhGppsdA5/Dw4Pjg.fmNP3aFkLnvPuhlPRwNcng)\n\n## License\n\n[MIT](LICENSE)\n","readmeFilename":"README.md"}