Need help with ali-ons?
Click the “chat” button below for chat support from the developer who created it, or find similar developers for support.

About the developer

ali-sdk
136 Stars 41 Forks MIT License 86 Commits 14 Opened issues

Description

Aliyun Open Notification Service Client

Services available

!
?

Need anything else?

Contributors list

ali-ons

NPM version build status David deps

Aliyun Open Notification Service Client (base on opensource project RocketMQ)

Sub module of ali-sdk.

Install

npm install ali-ons --save

Usage

consumer

'use strict';

const httpclient = require('urllib'); const Consumer = require('ali-ons').Consumer; const consumer = new Consumer({ httpclient, accessKeyId: 'your-accessKeyId', accessKeySecret: 'your-AccessKeySecret', consumerGroup: 'your-consumer-group', // namespace: '', // aliyun namespace support // isBroadcast: true, });

consumer.subscribe(config.topic, '*', async msg => { console.log(receive message, msgId: ${msg.msgId}, body: ${msg.body.toString()}) // return Consumer.ACTION_RETRY; // you can return ACTION_RETRY, then this message will be directly retried });

consumer.on('error', err => console.log(err));

producer

'use strict';
const httpclient = require('urllib');
const Producer = require('ali-ons').Producer;
const Message = require('ali-ons').Message;

const producer = new Producer({ httpclient, accessKeyId: 'your-accessKeyId', accessKeySecret: 'your-AccessKeySecret', producerGroup: 'your-producer-group', // namespace: '', // aliyun namespace support });

(async () => { const msg = new Message('your-topic', // topic 'TagA', // tag 'Hello ONS !!! ' // body );

// set Message#keys msg.keys = ['key1'];

// delay consume // msg.setStartDeliverTime(Date.now() + 5000);

const sendResult = await producer.send(msg); console.log(sendResult); })().catch(err => console.error(err))

Secure Keys

Please contact to @gxcsoccer to give you accessKey

License

MIT

We use cookies. If you continue to browse the site, you agree to the use of cookies. For more information on our use of cookies please see our Privacy Policy.