com.alipay.sofa.rpc.registry.zk.ZookeeperRegistry.subscribeConfig()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(2.1k)|赞(0)|评价(0)|浏览(115)

本文整理了Java中com.alipay.sofa.rpc.registry.zk.ZookeeperRegistry.subscribeConfig()方法的一些代码示例,展示了ZookeeperRegistry.subscribeConfig()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZookeeperRegistry.subscribeConfig()方法的具体详情如下:
包路径:com.alipay.sofa.rpc.registry.zk.ZookeeperRegistry
类名称:ZookeeperRegistry
方法名:subscribeConfig

ZookeeperRegistry.subscribeConfig介绍

[英]订阅接口级配置
[中]订阅接口级配置

代码示例

代码示例来源:origin: alipay/sofa-rpc

@Override
public void register(ProviderConfig config) {
  String appName = config.getAppName();
  if (!registryConfig.isRegister()) {
    if (LOGGER.isInfoEnabled(appName)) {
      LOGGER.infoWithApp(appName, LogCodes.getLog(LogCodes.INFO_REGISTRY_IGNORE));
    }
    return;
  }
  //发布
  if (config.isRegister()) {
    registerProviderUrls(config);
  }
  if (config.isSubscribe()) {
    // 订阅配置节点
    if (!INTERFACE_CONFIG_CACHE.containsKey(buildConfigPath(rootPath, config))) {
      //订阅接口级配置
      subscribeConfig(config, config.getConfigListener());
    }
  }
}

代码示例来源:origin: alipay/sofa-rpc

@Override
public void register(ProviderConfig config) {
  String appName = config.getAppName();
  if (!registryConfig.isRegister()) {
    if (LOGGER.isInfoEnabled(appName)) {
      LOGGER.infoWithApp(appName, LogCodes.getLog(LogCodes.INFO_REGISTRY_IGNORE));
    }
    return;
  }
  //发布
  if (config.isRegister()) {
    registerProviderUrls(config);
  }
  if (config.isSubscribe()) {
    // 订阅配置节点
    if (!INTERFACE_CONFIG_CACHE.containsKey(buildConfigPath(rootPath, config))) {
      //订阅接口级配置
      subscribeConfig(config, config.getConfigListener());
    }
  }
}

代码示例来源:origin: alipay/sofa-rpc

subscribeConfig(config, config.getConfigListener());

代码示例来源:origin: alipay/sofa-rpc

subscribeConfig(config, config.getConfigListener());

代码示例来源:origin: com.alipay.sofa/sofa-rpc-all

@Override
public void register(ProviderConfig config) {
  String appName = config.getAppName();
  if (!registryConfig.isRegister()) {
    if (LOGGER.isInfoEnabled(appName)) {
      LOGGER.infoWithApp(appName, LogCodes.getLog(LogCodes.INFO_REGISTRY_IGNORE));
    }
    return;
  }
  //发布
  if (config.isRegister()) {
    registerProviderUrls(config);
  }
  if (config.isSubscribe()) {
    // 订阅配置节点
    if (!INTERFACE_CONFIG_CACHE.containsKey(buildConfigPath(rootPath, config))) {
      //订阅接口级配置
      subscribeConfig(config, config.getConfigListener());
    }
  }
}

代码示例来源:origin: com.alipay.sofa/sofa-rpc-all

subscribeConfig(config, config.getConfigListener());

相关文章