We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 813fed5 commit 9031a4cCopy full SHA for 9031a4c
dubbo-registry/dubbo-registry-redis/src/main/java/org/apache/dubbo/registry/redis/RedisRegistry.java
@@ -564,7 +564,7 @@ public void run() {
564
jedis = jedisPool.getResource();
565
try {
566
if (service.endsWith(Constants.ANY_VALUE)) {
567
- if (!first) {
+ if (first) {
568
first = false;
569
Set<String> keys = jedis.keys(service);
570
if (CollectionUtils.isNotEmpty(keys)) {
@@ -576,7 +576,7 @@ public void run() {
576
}
577
jedis.psubscribe(new NotifySub(jedisPool), service); // blocking
578
} else {
579
580
581
doNotify(jedis, service);
582
resetSkip();
0 commit comments