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) {

Reply via email to