[incubator-dubbo] branch master updated: Merge pull request #3466, Condition is not properly used.

[liujun]

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 <ian....@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();