我尝试为 amqplib/callback_api 编写我的简单事件发射器包装器。当兔子不可用或断开连接时,我无法处理情况。我有getConnect
返回 Promise 的方法,该方法在建立连接时解决。但是如果连接被拒绝,Promise 显然会拒绝。如何在连接未建立时强制此方法重新连接
/**
* Async method getConnect for connection
* @returns {Promise<*>}
*/
getConnect = async () => {
return new Promise((resolve, reject) => {
amqp.connect(this.config.url, async function(err, conn) {
if (err) {
reject(err);
}
resolve(conn);
})
})
};
整个代码在这里https://github.com/kimonniez/rabbitEE
也许,我已经很困了,但我完全糊涂了:)提前谢谢!