You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by li...@apache.org on 2019/02/18 02:31:08 UTC
[incubator-dubbo] branch master updated: Merge pull request #3466,
Condition is not properly used.
This is an automated email from the ASF dual-hosted git repository.
liujun 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 9031a4c Merge pull request #3466, Condition is not properly used.
9031a4c is described below
commit 9031a4c20455ba16a63233f10783a55915afcd9b
Author: Ian Luo <ia...@gmail.com>
AuthorDate: Mon Feb 18 10:30:59 2019 +0800
Merge pull request #3466, Condition is not properly used.
fixes #1917
---
.../src/main/java/org/apache/dubbo/registry/redis/RedisRegistry.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 aa1f04e..5e4f899 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
@@ -564,7 +564,7 @@ public class RedisRegistry extends FailbackRegistry {
jedis = jedisPool.getResource();
try {
if (service.endsWith(Constants.ANY_VALUE)) {
- if (!first) {
+ if (first) {
first = false;
Set<String> keys = jedis.keys(service);
if (CollectionUtils.isNotEmpty(keys)) {
@@ -576,7 +576,7 @@ public class RedisRegistry extends FailbackRegistry {
}
jedis.psubscribe(new NotifySub(jedisPool), service); // blocking
} else {
- if (!first) {
+ if (first) {
first = false;
doNotify(jedis, service);
resetSkip();