### Question:
DistroConsistencyServiceImpl implements EphemeralConsistencyService, DistroDataProcessor { @Override public void put(String key, Record value) throws NacosException { onPut(key, value); distroProtocol.sync(new DistroKey(key, KeyBuilder.INSTANCE_LIST_KEY_PREFIX), DataOperation.CHANGE, globalConfig.getTaskDispatchPeriod() / 2); } DistroConsistencyServiceImpl(DistroMapper distroMapper, DataStore dataStore, Serializer serializer,
            SwitchDomain switchDomain, GlobalConfig globalConfig, DistroProtocol distroProtocol); @PostConstruct void init(); @Override void put(String key, Record value); @Override void remove(String key); @Override Datum get(String key); void onPut(String key, Record value); void onRemove(String key); void onReceiveChecksums(Map<String, String> checksumMap, String server); @Override boolean processData(DistroData distroData); @Override String processType(); @Override boolean processVerifyData(DistroData distroData); @Override boolean processSnapshot(DistroData distroData); @Override void listen(String key, RecordListener listener); @Override void unListen(String key, RecordListener listener); @Override boolean isAvailable(); boolean isInitialized();  }### Answer:
@Test public void testPutWithoutListener() throws NacosException { String key = KeyBuilder.buildInstanceListKey(TEST_NAMESPACE, TEST_SERVICE_NAME, true); distroConsistencyService.put(key, instances); verify(distroProtocol).sync(new DistroKey(key, KeyBuilder.INSTANCE_LIST_KEY_PREFIX), DataOperation.CHANGE, 1000L); verify(notifier, never()).addTask(key, DataOperation.CHANGE); verify(dataStore).put(eq(key), any(Datum.class)); }