fix the isRunning channel

tcncloud · Jan 29, 2025 · 8dfa855 · 8dfa855
1 parent be62e37
commit 8dfa855
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/core/src/main/java/com/tcn/exile/gateclients/GateClientJobStream.java b/core/src/main/java/com/tcn/exile/gateclients/GateClientJobStream.java
@@ -61,8 +61,12 @@ public boolean isRunning() {
 //      log.debug("channel is null, JobStream is not running");
       return false;
     }
+    if (channel.isTerminated()) return false;
+    if (channel.isShutdown()) return false;
+    return true;
 //    log.debug("channel {} shutdown {} terminated {} -> {}", channel, channel.isShutdown(), channel.isTerminated(), !channel.isShutdown() && !channel.isTerminated());
-    return (!channel.isShutdown() || !channel.isTerminated());
+//    var ret = !channel.isShutdown() && !channel.isTerminated();
+//    log.debug("JobStream is running {}", ret);
   }
 
   public synchronized void eventStream() {