public void shutdownNow(){
  shutdown=true;
  final Future<?> f=engineFuture.get();
  if (f != null) {
    if (log.isInfoEnabled())     log.info("Cancelling engineFuture: " + this);
    f.cancel(true);
  }
  final ExecutorService s=engineService.get();
  if (s != null) {
    if (log.isInfoEnabled())     log.info("Terminating engineService: " + this);
    s.shutdownNow();
  }
  final HttpClient cm=clientConnectionManagerRef.get();
  if (cm != null) {
    if (log.isInfoEnabled())     log.info("Terminating HttpClient: " + this);
    try {
      cm.stop();
    }
 catch (    Exception e) {
      log.error("Problem stopping HttpClient",e);
    }
  }
  for (  AbstractRunningQuery q : runningQueries.values()) {
    q.cancel(true);
  }
  priorityQueue.clear();
  deadlineQueue.clear();
  engineFuture.set(null);
  engineService.set(null);
  clientConnectionManagerRef.set(null);
}

public void shutdownNow ( ) { shutdown = true ; final Future < ? > f = engineFuture . get ( ) ; if ( f != null ) { if ( log . isInfoEnabled ( ) ) log . info ( "Cancelling engineFuture: " + this ) ; f . cancel ( true ) ; } final ExecutorService s = engineService . get ( ) ; if ( s != null ) { if ( log . isInfoEnabled ( ) ) log . info ( "Terminating engineService: " + this ) ; s . shutdownNow ( ) ; } final HttpClient cm = clientConnectionManagerRef . get ( ) ; if ( cm != null ) { if ( log . isInfoEnabled ( ) ) log . info ( "Terminating HttpClient: " + this ) ; try { cm . stop ( ) ; } catch ( Exception e ) { log . error ( "Problem stopping HttpClient" , e ) ; } } for ( AbstractRunningQuery q : runningQueries . values ( ) ) { q . cancel ( true ) ; } priorityQueue . clear ( ) ; deadlineQueue . clear ( ) ; engineFuture . set ( null ) ; engineService . set ( null ) ; clientConnectionManagerRef . set ( null ) ; }
do not accept new queries and halt any running binding set chunk tasks .
