This is an automated email from the ASF dual-hosted git repository.
rainyu pushed a commit to branch 3.3
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/3.3 by this push:
new 21c29089cd Fix: the interface-level timeout and retry configurations
become invalid after the caller application is restarted (#15784)
21c29089cd is described below
commit 21c29089cd95babc6949555273ac4d522d742ed6
Author: renyuwei <[email protected]>
AuthorDate: Thu Nov 20 17:00:25 2025 +0800
Fix: the interface-level timeout and retry configurations become invalid
after the caller application is restarted (#15784)
Details: By moving the subscription logic after initializing
referenceConfigurationListener in the dynamic configuration
Addresses: #15783
Co-authored-by: yuwei.ren <[email protected]>
---
.../dubbo/registry/integration/RegistryDirectory.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git
a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/RegistryDirectory.java
b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/RegistryDirectory.java
index 8c48ccb72c..c034b6cafe 100644
---
a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/RegistryDirectory.java
+++
b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/RegistryDirectory.java
@@ -145,6 +145,13 @@ public class RegistryDirectory<T> extends
DynamicDirectory<T> {
}
ApplicationModel applicationModel = url.getApplicationModel();
+ if (moduleModel
+ .modelEnvironment()
+ .getConfiguration()
+ .convert(Boolean.class,
org.apache.dubbo.registry.Constants.ENABLE_CONFIGURATION_LISTEN, true)) {
+ consumerConfigurationListener.addNotifyListener(this);
+ referenceConfigurationListener = new
ReferenceConfigurationListener(moduleModel, this, url);
+ }
String registryClusterName = registry.getUrl()
.getParameter(
RegistryConstants.REGISTRY_CLUSTER_KEY,
@@ -153,13 +160,6 @@ public class RegistryDirectory<T> extends
DynamicDirectory<T> {
super.subscribe(url);
return null;
});
- if (moduleModel
- .modelEnvironment()
- .getConfiguration()
- .convert(Boolean.class,
org.apache.dubbo.registry.Constants.ENABLE_CONFIGURATION_LISTEN, true)) {
- consumerConfigurationListener.addNotifyListener(this);
- referenceConfigurationListener = new
ReferenceConfigurationListener(moduleModel, this, url);
- }
}
private ConsumerConfigurationListener
getConsumerConfigurationListener(ModuleModel moduleModel) {