@Override
    public void closeStaleConnections() {

        logger.debug("closeStaleConnections() count before expiring: {}", getConnectionCount());

        connectionProvider.forEach((key, connection) -> {
            if (isStale(key)) {
                connectionProvider.close(key);
            }
        });

        logger.debug("closeStaleConnections() count after expiring: {}", getConnectionCount());
    }
@ Override public void closeStaleConnections ( ) { logger . debug ( "closeStaleConnections() count before expiring: {}" , getConnectionCount ( ) ) ; connectionProvider . forEach ( ( key , connection ) -> { if ( isStale ( key ) ) { connectionProvider . close ( key ) ; } } ) ; logger . debug ( "closeStaleConnections() count after expiring: {}" , getConnectionCount ( ) ) ; }
Close stale connections.