force channel reconnect on error

tcncloud · Jan 23, 2025 · e7aaf5b · e7aaf5b
1 parent 9dfb5f9
commit e7aaf5b
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/core/src/main/java/com/tcn/exile/gateclients/GateClientJobStream.java b/core/src/main/java/com/tcn/exile/gateclients/GateClientJobStream.java
@@ -118,11 +118,7 @@ public void onNext(Service.JobStreamResponse job) {
   public void onError(Throwable throwable) {
     log.debug("GateClientJobStream error {}", throwable.getMessage());
     channel.shutdownNow();
-//    if (isRunning()) {
-//      log.debug("shutting down channel");
-//      channel.shutdownNow();
-//    }
-//    eventStream();
+    eventStream();
   }
 
   @Override