本文整理了Java中com.alipay.sofa.rpc.registry.zk.ZookeeperRegistryHelper.convertConfigToAttribute()
方法的一些代码示例,展示了ZookeeperRegistryHelper.convertConfigToAttribute()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZookeeperRegistryHelper.convertConfigToAttribute()
方法的具体详情如下:
包路径:com.alipay.sofa.rpc.registry.zk.ZookeeperRegistryHelper
类名称:ZookeeperRegistryHelper
方法名:convertConfigToAttribute
[英]Convert child data to attribute.
[中]将子数据转换为属性。
代码示例来源:origin: alipay/sofa-rpc
/**
* Convert child data to attribute list.
*
* @param configPath the config path
* @param currentData the current data
* @return the attribute list
*/
static List<Map<String, String>> convertConfigToAttributes(String configPath,
List<ChildData> currentData) {
List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
if (CommonUtils.isEmpty(currentData)) {
return attributes;
}
for (ChildData childData : currentData) {
attributes.add(convertConfigToAttribute(configPath, childData, false));
}
return attributes;
}
代码示例来源:origin: alipay/sofa-rpc
/**
* Convert child data to attribute list.
*
* @param configPath the config path
* @param currentData the current data
* @return the attribute list
*/
static List<Map<String, String>> convertConfigToAttributes(String configPath,
List<ChildData> currentData) {
List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
if (CommonUtils.isEmpty(currentData)) {
return attributes;
}
for (ChildData childData : currentData) {
attributes.add(convertConfigToAttribute(configPath, childData, false));
}
return attributes;
}
代码示例来源:origin: alipay/sofa-rpc
private void notifyListeners(AbstractInterfaceConfig config, String configPath, ChildData data, boolean removeType) {
List<ConfigListener> configListeners = configListenerMap.get(config);
if (CommonUtils.isNotEmpty(configListeners)) {
//转换子节点Data为接口级配置<配置属性名,配置属性值>,例如<timeout,200>
Map<String, String> attribute = ZookeeperRegistryHelper.convertConfigToAttribute(configPath, data,
removeType);
for (ConfigListener listener : configListeners) {
listener.configChanged(attribute);
}
}
}
}
代码示例来源:origin: alipay/sofa-rpc
private void notifyListeners(AbstractInterfaceConfig config, String configPath, ChildData data, boolean removeType) {
List<ConfigListener> configListeners = configListenerMap.get(config);
if (CommonUtils.isNotEmpty(configListeners)) {
//转换子节点Data为接口级配置<配置属性名,配置属性值>,例如<timeout,200>
Map<String, String> attribute = ZookeeperRegistryHelper.convertConfigToAttribute(configPath, data,
removeType);
for (ConfigListener listener : configListeners) {
listener.configChanged(attribute);
}
}
}
}
代码示例来源:origin: alipay/sofa-rpc
/**
* Convert child data to attribute list.
*
* @param config the interface config
* @param overridePath the override path
* @param currentData the current data
* @return the attribute list
* @throws UnsupportedEncodingException decode exception
*/
static List<Map<String, String>> convertOverrideToAttributes(AbstractInterfaceConfig config,
String overridePath,
List<ChildData> currentData)
throws UnsupportedEncodingException {
List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
if (CommonUtils.isEmpty(currentData)) {
return attributes;
}
for (ChildData childData : currentData) {
String url = URLDecoder.decode(childData.getPath().substring(overridePath.length() + 1),
"UTF-8");
if (config instanceof ConsumerConfig) {
//If child data contains system local host, convert config to attribute
if (StringUtils.isNotEmpty(url) && StringUtils.isNotEmpty(SystemInfo.getLocalHost())
&& url.contains("://" + SystemInfo.getLocalHost() + "?")) {
attributes.add(convertConfigToAttribute(overridePath, childData, false));
}
}
}
return attributes;
}
代码示例来源:origin: alipay/sofa-rpc
/**
* Convert child data to attribute list.
*
* @param config the interface config
* @param overridePath the override path
* @param currentData the current data
* @return the attribute list
* @throws UnsupportedEncodingException decode exception
*/
static List<Map<String, String>> convertOverrideToAttributes(AbstractInterfaceConfig config,
String overridePath,
List<ChildData> currentData)
throws UnsupportedEncodingException {
List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
if (CommonUtils.isEmpty(currentData)) {
return attributes;
}
for (ChildData childData : currentData) {
String url = URLDecoder.decode(childData.getPath().substring(overridePath.length() + 1),
"UTF-8");
if (config instanceof ConsumerConfig) {
//If child data contains system local host, convert config to attribute
if (StringUtils.isNotEmpty(url) && StringUtils.isNotEmpty(SystemInfo.getLocalHost())
&& url.contains("://" + SystemInfo.getLocalHost() + "?")) {
attributes.add(convertConfigToAttribute(overridePath, childData, false));
}
}
}
return attributes;
}
代码示例来源:origin: com.alipay.sofa/sofa-rpc-all
/**
* Convert child data to attribute list.
*
* @param configPath the config path
* @param currentData the current data
* @return the attribute list
*/
static List<Map<String, String>> convertConfigToAttributes(String configPath,
List<ChildData> currentData) {
List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
if (CommonUtils.isEmpty(currentData)) {
return attributes;
}
for (ChildData childData : currentData) {
attributes.add(convertConfigToAttribute(configPath, childData, false));
}
return attributes;
}
代码示例来源:origin: com.alipay.sofa/sofa-rpc-all
private void notifyListeners(AbstractInterfaceConfig config, String configPath, ChildData data, boolean removeType) {
List<ConfigListener> configListeners = configListenerMap.get(config);
if (CommonUtils.isNotEmpty(configListeners)) {
//转换子节点Data为接口级配置<配置属性名,配置属性值>,例如<timeout,200>
Map<String, String> attribute = ZookeeperRegistryHelper.convertConfigToAttribute(configPath, data,
removeType);
for (ConfigListener listener : configListeners) {
listener.configChanged(attribute);
}
}
}
}
代码示例来源:origin: com.alipay.sofa/sofa-rpc-all
/**
* Convert child data to attribute list.
*
* @param config the interface config
* @param overridePath the override path
* @param currentData the current data
* @return the attribute list
* @throws UnsupportedEncodingException decode exception
*/
static List<Map<String, String>> convertOverrideToAttributes(AbstractInterfaceConfig config,
String overridePath,
List<ChildData> currentData)
throws UnsupportedEncodingException {
List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
if (CommonUtils.isEmpty(currentData)) {
return attributes;
}
for (ChildData childData : currentData) {
String url = URLDecoder.decode(childData.getPath().substring(overridePath.length() + 1),
"UTF-8");
if (config instanceof ConsumerConfig) {
//If child data contains system local host, convert config to attribute
if (StringUtils.isNotEmpty(url) && StringUtils.isNotEmpty(SystemInfo.getLocalHost())
&& url.contains("://" + SystemInfo.getLocalHost() + "?")) {
attributes.add(convertConfigToAttribute(overridePath, childData, false));
}
}
}
return attributes;
}
内容来源于网络,如有侵权,请联系作者删除!