3.2.1 • Published 7 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
7 years ago
3.2.0
7 years ago
3.1.7
7 years ago
3.1.6
7 years ago
3.1.5
7 years ago
3.1.4
7 years ago
3.1.3
7 years ago
3.1.2
7 years ago
3.1.1
7 years ago
3.1.0
7 years ago
4.0.2
7 years ago
4.0.1
7 years ago
4.0.0
7 years ago
3.0.1
7 years ago
3.0.0
7 years ago
2.2.0
7 years ago
2.1.1
7 years ago
2.1.0
7 years ago
2.0.1
7 years ago
2.0.0
7 years ago
1.3.3
7 years ago
1.3.2
7 years ago
1.3.1
7 years ago
1.3.0
7 years ago
1.2.6
7 years ago
1.2.5
7 years ago
1.2.4
7 years ago
1.2.3
7 years ago
1.2.2
7 years ago
1.2.1
7 years ago
1.2.0
7 years ago
1.1.6
7 years ago
1.1.5
7 years ago
1.1.4
7 years ago
1.1.3
7 years ago
1.1.2
7 years ago
1.1.1
7 years ago
1.1.0
7 years ago
1.0.18
8 years ago
1.0.17
8 years ago
1.0.16
8 years ago
1.0.15
8 years ago
1.0.14
8 years ago
1.0.13
8 years ago
1.0.12
8 years ago
1.0.11
8 years ago
1.0.10
8 years ago
1.0.9
8 years ago
1.0.8
8 years ago
1.0.7
8 years ago
1.0.6
8 years ago
1.0.5
8 years ago
1.0.4
8 years ago
1.0.3
8 years ago