}
        });

        assertTrue(listenerCalled.get());
    }

    /**
     * Test: Verify connected flag is set correctly
     */
    @Test
    public void testConnectedFlag() {
        assertFalse(fesenClient.connected());

        // After destroy, should be disconnected
        fesenClient.destroy();
        assertFalse(fesenClient.connected());
    }