From 9332ca553316efe97a30319fef8bcf925cf1535b Mon Sep 17 00:00:00 2001
From: zeaslity <zeaslity@qq.com>
Date: Fri, 13 Jan 2023 18:19:30 +0800
Subject: [PATCH] [ server ] [ execution ]-  execution log persistence
 accomplish -1

---
 .../io/wdd/rpc/execute/result/BuildStreamReader.java     | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/server/src/main/java/io/wdd/rpc/execute/result/BuildStreamReader.java b/server/src/main/java/io/wdd/rpc/execute/result/BuildStreamReader.java
index 17ff4cf..5775012 100644
--- a/server/src/main/java/io/wdd/rpc/execute/result/BuildStreamReader.java
+++ b/server/src/main/java/io/wdd/rpc/execute/result/BuildStreamReader.java
@@ -2,6 +2,7 @@ package io.wdd.rpc.execute.result;
 
 import io.wdd.rpc.execute.config.CommandReaderConfig;
 import io.wdd.server.utils.SpringUtils;
+import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.redis.connection.stream.ReadOffset;
 import org.springframework.data.redis.connection.stream.StreamOffset;
@@ -10,6 +11,7 @@ import org.springframework.stereotype.Component;
 
 import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.concurrent.TimeUnit;
 
 import static io.wdd.rpc.execute.result.RedisStreamReaderConfig.EXECUTION_RESULT_REDIS_STREAM_LISTENER_CONTAINER;
 
@@ -36,10 +38,13 @@ public class BuildStreamReader {
 
     }
 
+    @SneakyThrows
     private void modifyExecutionStreamReader(CommandReaderConfig commandReaderConfig) {
 
         // stop the old stream listener container
-        this.streamMessageListenerContainer.stop();
+        if (this.streamMessageListenerContainer.isRunning()) {
+            this.streamMessageListenerContainer.stop();
+        }
 
         // modify container
         this.streamMessageListenerContainer.receive(
@@ -52,7 +57,9 @@ public class BuildStreamReader {
                 )
         );
 
+
         // very important
+        TimeUnit.MILLISECONDS.sleep(500);
         this.streamMessageListenerContainer.start();
     }