This is an automated email from the ASF dual-hosted git repository.
iluo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git
The following commit(s) were added to refs/heads/master by this push:
new 58e35b2 应该是非空才循环,不然会导致在使用redis注册中心时消费者引用不到服务 (#3291)
58e35b2 is described below
commit 58e35b29444b62ba35e2b8050ccea589377f243b
Author: 鲁班学院-周瑜老师 <[email protected]>
AuthorDate: Tue Jan 29 14:14:42 2019 +0800
应该是非空才循环,不然会导致在使用redis注册中心时消费者引用不到服务 (#3291)
---
.../src/main/java/org/apache/dubbo/registry/redis/RedisRegistry.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/dubbo-registry/dubbo-registry-redis/src/main/java/org/apache/dubbo/registry/redis/RedisRegistry.java
b/dubbo-registry/dubbo-registry-redis/src/main/java/org/apache/dubbo/registry/redis/RedisRegistry.java
index e9dde9b..c958aa1 100644
---
a/dubbo-registry/dubbo-registry-redis/src/main/java/org/apache/dubbo/registry/redis/RedisRegistry.java
+++
b/dubbo-registry/dubbo-registry-redis/src/main/java/org/apache/dubbo/registry/redis/RedisRegistry.java
@@ -408,7 +408,7 @@ public class RedisRegistry extends FailbackRegistry {
}
List<URL> urls = new ArrayList<>();
Map<String, String> values = jedis.hgetAll(key);
- if (CollectionUtils.isEmptyMap(values)) {
+ if (!CollectionUtils.isEmptyMap(values)) {
for (Map.Entry<String, String> entry : values.entrySet()) {
URL u = URL.valueOf(entry.getKey());
if (!u.getParameter(Constants.DYNAMIC_KEY, true)