node-cmq

队列操作接口

消息操作

Example

// 创建cmq对象,`http://cmq-queue-gz.api.qcloud.com`需要根据你的服务器自行填写,参考: https://www.qcloud.com/doc/api/431/5832
const cmq = new CMQ('your SecretId', 'your SecretKey', 'http://cmq-queue-gz.api.qcloud.com')
cmq.CreateQueue('yourQueueName', (err,data) => {
 console.log('CreateQueue', err, data)
})

how to notifyMessage?

var _signStop = false
var notifyStop = function () {
 _signStop = true
}
var notifyRecv = function (queueName, done) {
 cmq.ReceiveMessage(queueName, 5, function (err, data) {
 if (_signStop) {
 console.log('notifyRecv is stop!')
 _signStop = false
 return
 }
 if (err) {
 console.log('notifyRecv-error', err)
 } else if (data.code === 0) {
 console.log('a message', data)
 if (done) {
 cmq.DeleteMessage(queueName, data.receiptHandle, (err, data) => {
 console.log('DeleteMessage', err, data)
 })
 }
 notifyRecv(queueName, done)
 } else {
 console.log('no message', data)
 notifyRecv(queueName, done)
 }
 })
}
notifyRecv('test779361906', true)
setTimeout(function () {
 notifyStop()
}, 10000)