public ConfigTransportClient getAgent() {
        return this.agent;
    }
@Test
    void testHandleConfigChangeReqeust() throws Exception {
        
        Properties prop = new Properties();
        String tenant = "c";
        
        prop.put(NAMESPACE, tenant);
        ServerListManager agent = Mockito.mock(ServerListManager.class);
        final NacosClientProperties nacosClientProperties = NacosClientProperties.PROTOTYPE.derive(prop);
        ClientWorker clientWorker = new ClientWorker(null, agent, nacosClientProperties);
        
        AtomicReference<Map<String, CacheData>> cacheMapMocked = Mockito.mock(AtomicReference.class);
        Field cacheMap = ClientWorker.class.getDeclaredField("cacheMap");
        cacheMap.setAccessible(true);
        cacheMap.set(clientWorker, cacheMapMocked);
        Map<String, CacheData> cacheDataMapMocked = Mockito.mock(Map.class);
        Mockito.when(cacheMapMocked.get()).thenReturn(cacheDataMapMocked);
        CacheData cacheDataMocked = Mockito.mock(CacheData.class);
        AtomicBoolean atomicBoolean = Mockito.mock(AtomicBoolean.class);
        Mockito.when(cacheDataMocked.getReceiveNotifyChanged()).thenReturn(atomicBoolean);
        String dataId = "a";
        String group = "b";
        Mockito.when(cacheDataMapMocked.get(GroupKey.getKeyTenant(dataId, group, tenant))).thenReturn(cacheDataMocked);
        ConfigChangeNotifyRequest configChangeNotifyRequest = ConfigChangeNotifyRequest.build(dataId, group, tenant);
        ((ClientWorker.ConfigRpcTransportClient) clientWorker.getAgent()).handleConfigChangeNotifyRequest(
                configChangeNotifyRequest, "testname");
        Mockito.verify(cacheDataMocked, times(1)).setConsistentWithServer(false);
        Mockito.verify(atomicBoolean, times(1)).set(true);
    }