void before() {
<BUG>if (circuitBreaker != null && !circuitBreaker.allowsExecution()) {
</BUG>
completed = true;
Exception failure = new CircuitBreakerOpenException();
<BUG>if (listeners != null)
listeners.handleComplete(null, failure, this, false);

future.complete(null, failure, fallback);
</BUG>
return;

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;
