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) {