This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch 3.2
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/3.2 by this push:
new 6b634b7650 Fix service key params when remove service instance
listener (#13272)
6b634b7650 is described below
commit 6b634b7650267ec4441fe4bc6e5886732adca67b
Author: Albumen Kevin <[email protected]>
AuthorDate: Fri Oct 27 17:46:19 2023 +0800
Fix service key params when remove service instance listener (#13272)
---
.../java/org/apache/dubbo/registry/client/ServiceDiscoveryRegistry.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/ServiceDiscoveryRegistry.java
b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/ServiceDiscoveryRegistry.java
index ec125e37be..1abd3831f9 100644
---
a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/ServiceDiscoveryRegistry.java
+++
b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/ServiceDiscoveryRegistry.java
@@ -258,7 +258,7 @@ public class ServiceDiscoveryRegistry extends
FailbackRegistry {
appSubscriptionLock.lock();
ServiceInstancesChangedListener instancesChangedListener =
serviceListeners.get(serviceNamesKey);
if (instancesChangedListener != null) {
-
instancesChangedListener.removeListener(protocolServiceKey, listener);
+
instancesChangedListener.removeListener(url.getServiceKey(), listener);
if (!instancesChangedListener.hasListeners()) {
instancesChangedListener.destroy();
serviceListeners.remove(serviceNamesKey);