(ListenerConfig<?, Object>) this);
callable.inject(execution);
try {
future.setFuture((Future<T>) scheduler.schedule(callable, 0, TimeUnit.MILLISECONDS));
} catch (Throwable t) {
<BUG>complete(null, t, execution, false);
</BUG>
future.complete(null, t);
}
return future;

(ListenerConfig<?, Object>) this);
callable.inject(execution);
try {
future.setFuture((Future<T>) scheduler.schedule(callable, 0, TimeUnit.MILLISECONDS));
} catch (Throwable t) {
handleComplete(null, t, execution, false);
future.complete(null, t);
}
return future;
