set listener to deamon thread

Signed-off-by: c00603587 <[email protected]>
redis · Sep 20, 2023 · 33c6ece · 33c6ece
1 parent ec1e92f
commit 33c6ece
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/src/main/java/redis/clients/jedis/JedisSentinelPool.java b/src/main/java/redis/clients/jedis/JedisSentinelPool.java
@@ -202,7 +202,7 @@ private void initMasterListeners(Set<HostAndPort> sentinels, String masterName)
   private void initMasterListeners(Set<HostAndPort> sentinels, String masterName,
       GenericObjectPoolConfig<Jedis> poolConfig) {
 
-    LOG.info("Init master node listener {}", masterName);
+    LOG.info("Starting Sentinel listeners for {}...", masterName);
     SentinelPoolConfig jedisSentinelPoolConfig = null;
     if (poolConfig instanceof SentinelPoolConfig) {
       jedisSentinelPoolConfig = ((SentinelPoolConfig) poolConfig);
@@ -232,7 +232,6 @@ public void onChange(HostAndPort hostAndPort) {
         });
       }
     }
-
     masterListeners.forEach(SentinelMasterListener::start);
   }
 

diff --git a/src/main/java/redis/clients/jedis/SentinelMasterActiveDetectListener.java b/src/main/java/redis/clients/jedis/SentinelMasterActiveDetectListener.java
@@ -36,6 +36,7 @@ public SentinelMasterActiveDetectListener(HostAndPort currentHostMaster, HostAnd
     this.jedisClientConfig = jedisClientConfig;
     this.masterName = masterName;
     this.activeDetectIntervalTimeMillis = activeDetectIntervalTimeMillis;
+    this.setDaemon(true);
   }
 
   @Override

diff --git a/src/main/java/redis/clients/jedis/SentinelMasterSubscribeListener.java b/src/main/java/redis/clients/jedis/SentinelMasterSubscribeListener.java
@@ -33,6 +33,7 @@ public SentinelMasterSubscribeListener(String masterName, HostAndPort sentinel,
     this.sentinel = sentinel;
     this.sentinelClientConfig = sentinelClientConfig;
     this.subscribeRetryWaitTimeMillis = subscribeRetryWaitTimeMillis;
+    this.setDaemon(true);
   }
 
   @Override