public synchronized boolean removeSuspendedResponse(WorkerCategory category,Response response){
  Deque<Response> deque=workersByCategory.get(category);
  if (deque == null) {
    return false;
  }
  if (deque.remove(response)) {
    nWaitingConsumers-=1;
    LOG.debug("Removed closed connection from queue.");
    return true;
  }
  return false;
}

public synchronized boolean removeSuspendedResponse ( WorkerCategory category , Response response ) { Deque < Response > deque = workersByCategory . get ( category ) ; if ( deque == null ) { return false ; } if ( deque . remove ( response ) ) { nWaitingConsumers -= 1 ; LOG . debug ( "Removed closed connection from queue." ) ; return true ; } return false ; }
when we notice that a long poll connection has closed , we remove it here .
