if (isConnectionUnhealthy(transport)) {
                    unhealthy.add(transport);
                    String key = getConnectionKey(transport);
                    recordConnectionFailure(key);
                    log.debug("Removing unhealthy connection: {}", transport);
                }
            } catch (Exception e) {