[ server ] [ executor ] - redis stream listener container all procedure -1

2022-12-30 15:30:12 +08:00
parent adc78fa666
commit a4a6c84fd8
5 changed files with 15 additions and 18 deletions
--- a/server/src/main/java/io/wdd/rpc/execute/result/CreateStreamReader.java
+++ b/server/src/main/java/io/wdd/rpc/execute/result/CreateStreamReader.java
@@ -38,6 +38,12 @@ public class CreateStreamReader implements ApplicationContextAware {
        // prepare the environment
        prepareEnv();

+        // oldStreamKey equals streamKey don't need to do anything , just return
+        if (redisStreamReaderConfig.getStreamKey().equals(streamKey)) {
+            log.debug("redis listener container not change !");
+            return;
+        }
+
        // destroy the REDIS_STREAM_LISTENER_CONTAINER
        destroyStreamReader(streamKey);