From e5c0187f3c7921767b6dcc697d7dd7c26fdcb39d Mon Sep 17 00:00:00 2001 From: ymlam Date: Wed, 8 Feb 2023 00:23:54 -0500 Subject: [PATCH] Transmit ABORT reason when setting BroadcastState to ABORT --- src/main/java/altk/comm/engine/Broadcast.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main/java/altk/comm/engine/Broadcast.java b/src/main/java/altk/comm/engine/Broadcast.java index 8085cdf..e030ce6 100644 --- a/src/main/java/altk/comm/engine/Broadcast.java +++ b/src/main/java/altk/comm/engine/Broadcast.java @@ -1274,7 +1274,7 @@ public abstract class Broadcast */ public void postJobStatus(Job job) { - if (job.isBroadcastFatal()) setState(BroadcastState.ABORTING); + if (job.isBroadcastFatal()) setState(BroadcastState.ABORTING, job.getErrorText(), null); if (job.jobStatus == CommJobStatus.SUCCESS) successCount.incrementAndGet(); if (postback != null) { @@ -1419,7 +1419,9 @@ public abstract class Broadcast * @return */ public PostbackThreadActionOnEmpty getPostbackThreadActionOnEmpty() { - myLogger.debug("getPostbackThreadActionOnEmpty(): broadcast state " + state); + myLogger.debug(String.format( + "getPostbackThreadActionOnEmpty(): broadcast state %s, serviceActivityCount %d", + state, serviceActivityCount)); if (state.isFinal) return PostbackThreadActionOnEmpty.STOP; if (serviceActivityCount > 0) {