@Override public void onFailure(TaskCallback callback,Throwable t){
  try {
    state.doneProcess();
    abort(t);
    TaskCallbackImpl callbackImpl=(TaskCallbackImpl)callback;
    callbackManager.updateCallback(callbackImpl,false);
    log.error("Got callback failure for task {}",callbackImpl.taskName);
  }
 catch (  Throwable e) {
    log.error(e.getMessage(),e);
  }
 finally {
    resume();
  }
}

@ Override public void onFailure ( TaskCallback callback , Throwable t ) { try { state . doneProcess ( ) ; abort ( t ) ; TaskCallbackImpl callbackImpl = ( TaskCallbackImpl ) callback ; callbackManager . updateCallback ( callbackImpl , false ) ; log . error ( "Got callback failure for task {}" , callbackImpl . taskName ) ; } catch ( Throwable e ) { log . error ( e . getMessage ( ) , e ) ; } finally { resume ( ) ; } }
task process fails . trigger the listener indicating failure .
