verify(mockLoadBalancer).selectChannel(mockOperation);
        verify(alternativeChannel).addPendingOperation(mockOperation);
    }

    @Test
    void testFailureWithNoAlternativeChannels() throws Exception {
        failedChannel.addPendingOperation(mockOperation);

    @Test
    void testLeastLoadedStrategy() {
        loadBalancer.setStrategy(LoadBalancingStrategy.LEAST_LOADED);

        // Add pending operations to channel1 to make it more loaded
        channel1.addPendingOperation(mockMessage);

        when(mockChannelManager.getHealthyChannels()).thenReturn(Arrays.asList(channel1, channel2));

        ChannelInfo selected = loadBalancer.selectChannel(mockMessage);

        channelInfo.addPendingOperation(mockOperation);
        assertEquals(1, channelInfo.getRequestsPending());
        assertFalse(channelInfo.getPendingOperations().isEmpty());

        assertTrue(channelInfo.removePendingOperation(mockOperation));
        assertEquals(0, channelInfo.getRequestsPending());

        channelInfo.addPendingOperation(mockOperation);

        return pendingOperations;
    }

    /**
     * Add a pending operation
     *
     * @param operation operation to add
     */
    public void addPendingOperation(CommonServerMessageBlock operation) {
        pendingOperations.add(operation);
    }

    /**
     * Remove a pending operation
     *
     * @param operation operation to remove

        for (CommonServerMessageBlock op : operationsCopy) {
            try {
                ChannelInfo alternativeChannel = manager.getLoadBalancer().selectChannel(op);
                alternativeChannel.addPendingOperation(op);
                // Operation would be resent on alternative channel
                // For now, skip actual send implementation
            } catch (Exception e) {