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

void before() {
if (circuitBreaker != null && !circuitBreaker.allowsExecution()) {
completed = true;
Exception failure = new CircuitBreakerOpenException();
if (listeners != null)
listeners.handleComplete(null, failure, this, false);
future.complete(null, failure);
return;
}
