ymlam
2 years ago
1 changed files with 4 additions and 2 deletions
Unified View
Diff Options
+ 4
- 2
src/main/java/altk/comm/engine/Broadcast.java
View File
| @@ -1274,7 +1274,7 @@ public abstract class Broadcast | |||||
| */ | */ | ||||
| public void postJobStatus(Job job) | 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 (job.jobStatus == CommJobStatus.SUCCESS) successCount.incrementAndGet(); | ||||
| if (postback != null) | if (postback != null) | ||||
| { | { | ||||
| @@ -1419,7 +1419,9 @@ public abstract class Broadcast | |||||
| * @return | * @return | ||||
| */ | */ | ||||
| public PostbackThreadActionOnEmpty getPostbackThreadActionOnEmpty() { | 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 (state.isFinal) return PostbackThreadActionOnEmpty.STOP; | ||||
| if (serviceActivityCount > 0) { | if (serviceActivityCount > 0) { | ||||