Skip to content

Commit b57add9

Browse files
committed
fix: prevent shutdown of all job streams by commenting out static channel shutdown logic
1 parent 7c9474e commit b57add9

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

core/src/main/java/com/tcn/exile/gateclients/v2/GateClientJobStream.java

+6-3
Original file line numberDiff line numberDiff line change
@@ -74,9 +74,12 @@ public void start() {
7474
log.debug("Tenant: {} - Thread {} acquired streamLock.", tenant, Thread.currentThread().getName());
7575
try {
7676
log.debug("Tenant: {} - Attempting to start job stream", tenant);
77-
if (!isRunning()) {
78-
shutdown(); // shutdown() acts on static channel
79-
}
77+
// THIS WAS ISSUING A SHUTDOWN ON THE STATIC CHANNEL AND CAUSING ALL JOB STREAMS TO STOP
78+
// if (!isRunning()) {
79+
// log.debug("Tenant: {} - is not running then attempting to shutdown job stream", tenant);
80+
// shutdown(); // shutdown() acts on static channel
81+
// }
82+
8083
// Use getChannel() directly here
8184
this.client = GateServiceGrpc.newStub(getChannel())
8285
.withDeadlineAfter(30, TimeUnit.SECONDS)

0 commit comments

Comments
 (0)