com.alibaba.dubbo.registry.zookeeper.ZookeeperRegistry.subscribe()方法的使用及代码示例

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

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

ZookeeperRegistry.subscribe介绍

暂无

代码示例

代码示例来源:origin: com.alibaba/dubbo

@Override
  public void childChanged(String parentPath, List<String> currentChilds) {
    for (String child : currentChilds) {
      child = URL.decode(child);
      if (!anyServices.contains(child)) {
        anyServices.add(child);
        subscribe(url.setPath(child).addParameters(Constants.INTERFACE_KEY, child,
            Constants.CHECK_KEY, String.valueOf(false)), listener);
      }
    }
  }
});

代码示例来源:origin: remoting/dubbox

public void childChanged(String parentPath, List<String> currentChilds) {
    for (String child : currentChilds) {
      child = URL.decode(child);
      if (! anyServices.contains(child)) {
        anyServices.add(child);
        subscribe(url.setPath(child).addParameters(Constants.INTERFACE_KEY, child, 
            Constants.CHECK_KEY, String.valueOf(false)), listener);
      }
    }
  }
});

代码示例来源:origin: remoting/dubbox

public void childChanged(String parentPath, List<String> currentChilds) {
    for (String child : currentChilds) {
      child = URL.decode(child);
      if (! anyServices.contains(child)) {
        anyServices.add(child);
        subscribe(url.setPath(child).addParameters(Constants.INTERFACE_KEY, child, 
            Constants.CHECK_KEY, String.valueOf(false)), listener);
      }
    }
  }
});

代码示例来源:origin: remoting/dubbox

service = URL.decode(service);
anyServices.add(service);
subscribe(url.setPath(service).addParameters(Constants.INTERFACE_KEY, service, 
    Constants.CHECK_KEY, String.valueOf(false)), listener);

代码示例来源:origin: com.alibaba/dubbo

service = URL.decode(service);
anyServices.add(service);
subscribe(url.setPath(service).addParameters(Constants.INTERFACE_KEY, service,
    Constants.CHECK_KEY, String.valueOf(false)), listener);

代码示例来源:origin: remoting/dubbox

service = URL.decode(service);
anyServices.add(service);
subscribe(url.setPath(service).addParameters(Constants.INTERFACE_KEY, service, 
    Constants.CHECK_KEY, String.valueOf(false)), listener);

相关文章