question: 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 ; }
target:  When we notice that a long poll connection has closed, we remove it here. 