У меня есть этот код
async connection(c: DependencyContainer): Promise<Connection|undefined> {
const breaker = new CircuitBreaker((uri: string) => {
return connect(uri)
});
breaker.on('failure', (err) => {
c.resolve<Logger>(InjectToken.Logger).warn('amqp ', err);
});
return await breaker.fire(c.resolve<string>(InjectToken.AmqpUri));
}
Я вижу, что он вызывается один раз, и вызывается failure
, хотя его запуск невозможен, поскольку сервер, на который я указал (localhost) не в сети. Что я делаю не так?