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

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

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

ZookeeperProviderObserver.addProvider介绍

[英]Add provider
[中]添加提供者

代码示例

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

@Override
  public void childEvent(CuratorFramework client1, PathChildrenCacheEvent event) throws Exception {
    if (LOGGER.isDebugEnabled(config.getAppName())) {
      LOGGER.debugWithApp(config.getAppName(),
        "Receive zookeeper event: " + "type=[" + event.getType() + "]");
    }
    switch (event.getType()) {
      case CHILD_ADDED: //加了一个provider
        providerObserver.addProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_REMOVED: //删了一个provider
        providerObserver.removeProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_UPDATED: // 更新一个Provider
        providerObserver.updateProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      default:
        break;
    }
  }
});

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

@Override
  public void childEvent(CuratorFramework client1, PathChildrenCacheEvent event) throws Exception {
    if (LOGGER.isDebugEnabled(config.getAppName())) {
      LOGGER.debugWithApp(config.getAppName(),
        "Receive zookeeper event: " + "type=[" + event.getType() + "]");
    }
    switch (event.getType()) {
      case CHILD_ADDED: //加了一个provider
        providerObserver.addProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_REMOVED: //删了一个provider
        providerObserver.removeProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_UPDATED: // 更新一个Provider
        providerObserver.updateProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      default:
        break;
    }
  }
});

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

@Override
  public void childEvent(CuratorFramework client1, PathChildrenCacheEvent event) throws Exception {
    if (LOGGER.isDebugEnabled(config.getAppName())) {
      LOGGER.debugWithApp(config.getAppName(),
        "Receive zookeeper event: " + "type=[" + event.getType() + "]");
    }
    switch (event.getType()) {
      case CHILD_ADDED: //加了一个provider
        providerObserver.addProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_REMOVED: //删了一个provider
        providerObserver.removeProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_UPDATED: // 更新一个Provider
        providerObserver.updateProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      default:
        break;
    }
  }
});

相关文章