protected JobLauncherExecutionDriver(JobSpec jobSpec, Logger log, DriverRunnable runnable) {
  super(runnable);
  _closer = Closer.create();
  _closer.register(runnable.getJobLauncher());
  _log = log;
  _jobSpec = jobSpec;
  _jobExec = runnable.getJobExec();
  _callbackDispatcher = _closer.register(runnable.getCallbackDispatcher());
  _jobState = runnable.getJobState();
  _executionList = new ExecutionList();
  _runnable = runnable;
}
 

@Override
public ExecutionList getListeners() {
    return listeners;
}
 

private CancellingListenableForwardingFutureForTask(BasicExecutionManager execMgmt, Future<T> delegate, ExecutionList list, Task<T> task) {
    super(delegate);
    this.listeners = list;
    this.execMgmt = execMgmt;
    this.task = task;
}
 

public ExecutionList getListeners() {
    return listeners;
}
 

@Override
public ExecutionList getListeners() {
    return delegate().getListeners();
}
 

ExecutionList getListeners();