// Clear failover state on success
            failoverStates.remove(channel.getChannelId());

            log.info("Successfully recovered channel {}", channel.getChannelId());

        } catch (Exception e) {
            log.warn("Failed to recover channel {}: {}", channel.getChannelId(), e.getMessage());

            // Schedule next retry or remove
            handleFailure(channel, e);

                    if (!isHealthy) {
                        log.warn("Channel {} is unhealthy", channel.getChannelId());
                    }
                } catch (Exception e) {
                    log.warn("Health check failed for channel {}: {}", channel.getChannelId(), e.getMessage());
                    channel.setHealthy(false);
                }
            }
        }
    }

                failoverStates.remove(channel.getChannelId());
                
                log.info("Successfully recovered channel {}", channel.getChannelId());
                
            } catch (Exception e) {
                log.warn("Failed to recover channel {}: {}", 
                    channel.getChannelId(), e.getMessage());
                
                // Schedule next retry or remove

                    log.debug("Keep-alive failed for channel {}", channel.getChannelId());
                    handleChannelFailure(channel, e);
                }
            }

            // Check error rate
            if (channel.getErrorRate() > 0.1) {
                log.warn("High error rate on channel {}: {}", channel.getChannelId(), channel.getErrorRate());
            }
        }
    }

        this.isPrimary = false;
        this.pendingOperations = new CopyOnWriteArrayList<>();
    }

    /**
     * Get channel ID
     *
     * @return channel identifier
     */
    public String getChannelId() {
        return channelId;
    }

    /**
     * Get the transport for this channel
     *
     * @return SMB transport
     */
    public SmbTransport getTransport() {
        return transport;