import com.hazelcast.map.listener.EntryUpdatedListener; //导入依赖的package包/类
private void initBean(RefreshableConfiguration refreshableConfiguration) {
    IMap<String, String> configMap = hazelcastInstance.getMap(TENANT_CONFIGURATION_MAP);

    configMap.forEach((key, value) -> {
        if (refreshableConfiguration.isListeningConfiguration(key)) {

            log.info(
                "Process config init event: [key = {}, size = {}, newHash = {}] in bean: [{}]",
                key,
                StringUtils.length(value),
                getValueHash(value),
                getBeanName(refreshableConfiguration));

            refreshableConfiguration.onInit(key, value);
        }
    });

    log.info("refreshable configuration bean [{}] initialized by configMap with {} entries",
             getBeanName(refreshableConfiguration), configMap.size());

    final boolean includeValue = true;
    configMap.addEntryListener((EntryAddedListener<String, String>) e -> {
        onEntryChange(refreshableConfiguration, e, configMap);
    }, includeValue);
    configMap.addEntryListener((EntryRemovedListener<String, String>) e -> {
        onEntryChange(refreshableConfiguration, e, configMap);
    }, includeValue);
    configMap.addEntryListener((EntryUpdatedListener<String, String>) e -> {
        onEntryChange(refreshableConfiguration, e, configMap);
    }, includeValue);
}