node-metaq-client

metaq client

node-metaq-client

$ npm install node-metaq-client
var metaq = require('node-metaq-client');
 
 * @param {object} options config
 *   - accessKey
 *   - secretKey
 *   - metaRestHost
 *   - metaqRestVersion
 *   - group
 *   - tairDiamondHost
 *   - tairDataId
 *   - tairNamespace
 *   - conCount  消费并发数,默认: 1
 *   - capacity 收消息队列缓存个数
 
var client = metaq.createClient({
  accessKey : 'a885c583',
  secretKey : 'a885c583-a6b5-401d-9f0f-aebc328c6466',
  metaqRestHost : 'http://10.235.170.6:80',
  metaqRestVersion : '2014-04-01',
  group: 'app'
  //tairDiamondHost : 'xxx', 
  //tairDataId : 'xx', 
  //tairNamespace : xx 
});
 
client.on('c_error',function(err){
  console.log('metaq client error:', err.msg, err.stack);
});
 
client.send('lk-test','message', function (err,data){
  if(err){
    console.log('err' + err);
  }
});
 
client.subscribe('lk-test',null,function(err,msg,notify) {
  console.log(msg);
  //do... 
  //异步处理完成后,调notify(),接收下一条消息 
  notify();
},function(err,data) {
  if(!err) {
    console.log('subscribe success.');
  }
});