qcloud cmq sdk modified from pis-qcloud-cmq
npm install fjx-qcloud-cmqpis-qcloud-cmq,在此基础上做了如下修改:
sh
npm install fjx-qcloud-cmq --save
`
Example
`js
// 队列模型
const MQ = require('fjx-qcloud-cmq').CMQQ
// 主题模型
const MT = reuqire('fjx-qcloud-cmq').CMQT
// 填写相关配置,设置是否为内网模式(默认为外网调用)
const cmqApi = new MQ('SecretId','SecretKey','Region',false)
// 根据文档调用方法即可
cmqApi.AssertQueueAsync(queue_name).then(function(q){
return q
}).then(() => {
// 发送书籍推送到消息队列
return cmqApi.SendMessageAsync(queue_name, 'test').then(function(res){
console.log(res)
// 发送失败(更新状态)
if (res.code) {
return done(res)
}
return done()
})
}).catch((err) => {
console.log(err)
done(err)
})
``