This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/master by this push:
new e05494d [master] revert
AbstractConfiguratorListener#genConfiguratorsFromRawRule (#9249)
e05494d is described below
commit e05494dea846bfea60727b1e5135efed2ffbf6b1
Author: zrlw <[email protected]>
AuthorDate: Thu Nov 18 20:09:45 2021 +0800
[master] revert AbstractConfiguratorListener#genConfiguratorsFromRawRule
(#9249)
* ignore event content parse failure
* support single ip
* revert genConfiguratorsFromRawRule
---
.../registry/integration/AbstractConfiguratorListener.java | 14 ++++++--------
1 file changed, 6 insertions(+), 8 deletions(-)
diff --git
a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/AbstractConfiguratorListener.java
b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/AbstractConfiguratorListener.java
index 3f3b2c7..13e8527 100644
---
a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/AbstractConfiguratorListener.java
+++
b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/AbstractConfiguratorListener.java
@@ -60,11 +60,10 @@ public abstract class AbstractConfiguratorListener
implements ConfigurationListe
", raw config content is:\n " + event.getContent());
}
- if (event.getChangeType().equals(ConfigChangeType.ADDED)) {
- return;
- } else if (event.getChangeType().equals(ConfigChangeType.DELETED)) {
+ if (event.getChangeType().equals(ConfigChangeType.DELETED)) {
configurators.clear();
} else {
+ // ADDED or MODIFIED
if (!genConfiguratorsFromRawRule(event.getContent())) {
return;
}
@@ -74,17 +73,16 @@ public abstract class AbstractConfiguratorListener
implements ConfigurationListe
}
private boolean genConfiguratorsFromRawRule(String rawConfig) {
- boolean parseSuccess = true;
try {
// parseConfigurators will recognize app/service config
automatically.
configurators =
Configurator.toConfigurators(ConfigParser.parseConfigurators(rawConfig))
.orElse(configurators);
} catch (Exception e) {
- logger.error("Failed to parse raw dynamic config and it will not
take effect, the raw config is: " +
- rawConfig, e);
- parseSuccess = false;
+ logger.warn("Failed to parse raw dynamic config and it will not
take effect, the raw config is: "
+ + rawConfig + ", cause: " + e.getMessage());
+ return false;
}
- return parseSuccess;
+ return true;
}
protected abstract void notifyOverrides();