3.2.1 • Published 5 years ago
cw-rabbitmq v3.2.1
rabbitmq 组件
消息队列组件,推荐Node版本 8LTS 以上
安装
npm install --save cw-rabbitmq
使用方法
const connConfig = {
host: '',
port: 5672,
login: '',
password: '',
vhost: '',
reconnect: true,
reconnectBackoffTime: 10000, // 10秒尝试连接一次
};
const options = {
exchangeName: 'exTest',
exchangeOption: {
// ke选
type: 'direct',
autoDelete: false,
confirm: true,
},
queueName: 'test',
queueOption: {
// 可选
durable: true,
autoDelete: false,
},
};
const mq = new MQ(connConfig, options);
mq.publishMsg('heartbeat-test')
.then(result => {
console.info(`MQ心跳监测正常,result:${result}`);
})
.catch(err => {
console.info(`MQ心跳监测异常${err.toString()}`);
});
mq.subscribeAsync().then(result => {
result.ack.acknowledge(true);
});
mq.subscribe((message, headers, deliveryInfo, ack) => {
ack.acknowledge(true);
});
3.2.1
5 years ago
3.2.0
5 years ago
3.1.7
5 years ago
3.1.6
5 years ago
3.1.5
5 years ago
3.1.4
6 years ago
3.1.3
6 years ago
3.1.2
6 years ago
3.1.1
6 years ago
3.1.0
6 years ago
4.0.2
6 years ago
4.0.1
6 years ago
4.0.0
6 years ago
3.0.1
6 years ago
3.0.0
6 years ago
2.2.0
6 years ago
2.1.1
6 years ago
2.1.0
6 years ago
2.0.1
6 years ago
2.0.0
6 years ago
1.3.3
6 years ago
1.3.2
6 years ago
1.3.1
6 years ago
1.3.0
6 years ago
1.2.6
6 years ago
1.2.5
6 years ago
1.2.4
6 years ago
1.2.3
6 years ago
1.2.2
6 years ago
1.2.1
6 years ago
1.2.0
6 years ago
1.1.6
6 years ago
1.1.5
6 years ago
1.1.4
6 years ago
1.1.3
6 years ago
1.1.2
6 years ago
1.1.1
6 years ago
1.1.0
6 years ago
1.0.18
6 years ago
1.0.17
6 years ago
1.0.16
6 years ago
1.0.15
6 years ago
1.0.14
6 years ago
1.0.13
6 years ago
1.0.12
6 years ago
1.0.11
6 years ago
1.0.10
6 years ago
1.0.9
6 years ago
1.0.8
6 years ago
1.0.7
6 years ago
1.0.6
6 years ago
1.0.5
6 years ago
1.0.4
6 years ago
1.0.3
6 years ago