assertTrue(e.getCause().getMessage().contains("Failed to create multi-channel transport"));
        }
    }

    @Test
    @DisplayName("MultiChannelManager should shutdown cleanly")
    void testShutdown() {
        assertDoesNotThrow(() -> {
            multiChannelManager.shutdown();
        });
    }

    @Test
    @DisplayName("createDefaultContext should work")

    }

    @Test
    public void testGetMaxMessageSize() {
        assertEquals(65536, provider.getMaxMessageSize(), "TCP provider should have 64KB limit");
    }

    @Test
    public void testShutdown() {
        // Should not throw exception
        assertDoesNotThrow(() -> provider.shutdown());
    }

        verify(mockChannelManager, atLeast(1)).removeChannel(failedChannel);
        verify(mockChannelManager, atLeast(1)).establishReplacementChannel();
    }

    @Test
    void testShutdown() {
        failover.shutdown();

        // Should not throw any exceptions
        assertDoesNotThrow(() -> failover.shutdown());
    }

    @Test

        // Remove should not throw exception even if channel doesn't exist
        assertDoesNotThrow(() -> channelManager.removeChannel(channel));
    }

    @Test
    void testShutdown() {
        assertDoesNotThrow(() -> channelManager.shutdown());

        // Multiple shutdowns should be safe
        assertDoesNotThrow(() -> channelManager.shutdown());
    }

    @Test

        // Verify base lease manager was called
        verify(baseLeaseManager).releaseLease(leaseKey);
    }

    @Test
    public void testShutdown() {
        String directoryPath = "/test/dir";
        Smb2LeaseKey leaseKey = new Smb2LeaseKey();

        // Create cache entry

        // Verify only second listener is called
        jobExecutor.shutdown();
        assertEquals(10, callCount.get());
    }

    public void test_shutdown() {
        // Test shutdown with listener
        AtomicBoolean shutdownCalled = new AtomicBoolean(false);
        jobExecutor.addShutdownListener(new ShutdownListener() {
            @Override