@ Override public void destroy ( SocketDestination dest , ClientRequestExecutor clientRequestExecutor ) throws Exception { clientRequestExecutor . close ( ) ; int numDestroyed = destroyed . incrementAndGet ( ) ; if ( stats != null ) { stats . incrementCount ( dest , ClientSocketStats . Tracked . CONNECTION_DESTROYED_EVENT ) ; } if ( logger . isDebugEnabled ( ) ) logger . debug ( "Destroyed socket " + numDestroyed + " connection to " + dest . getHost ( ) + ":" + dest . getPort ( ) ) ; }
Close the ClientRequestExecutor .