
future.complete(null, failure, fallback);
</BUG>
return;
}
<BUG>if (completeCalled && listeners != null)

listeners.handleRetry(lastResult, lastFailure, this);
</BUG>
super.before();

void before() {
if (config.circuitBreaker != null && !config.circuitBreaker.allowsExecution()) {
completed = true;
Exception failure = new CircuitBreakerOpenException();
if (config != null)
config.handleComplete(null, failure, this, false);
future.complete(null, failure, config.fallback);
return;
}
if (completeCalled && config != null)
config.handleRetry(lastResult, lastFailure, this);
super.before();
