From 44e771a8f62928ac9b7bc280f9d687d8b4522153 Mon Sep 17 00:00:00 2001 From: ymlam Date: Tue, 3 Jan 2023 15:12:34 -0500 Subject: [PATCH] Allow a job to cause broadcast to abort at time posting Achieved by adding the isBroadcastFatal method to Job class. --- src/main/java/altk/comm/engine/Broadcast.java | 1 + src/main/java/altk/comm/engine/Job.java | 9 +++++++++ 2 files changed, 10 insertions(+) diff --git a/src/main/java/altk/comm/engine/Broadcast.java b/src/main/java/altk/comm/engine/Broadcast.java index 9189034..2538d27 100644 --- a/src/main/java/altk/comm/engine/Broadcast.java +++ b/src/main/java/altk/comm/engine/Broadcast.java @@ -1271,6 +1271,7 @@ public abstract class Broadcast */ public void postJobStatus(Job job) { + if (job.isBroadcastFatal()) setState(BroadcastState.ABORTING); if (job.jobStatus == CommJobStatus.SUCCESS) successCount.incrementAndGet(); if (postback != null) { diff --git a/src/main/java/altk/comm/engine/Job.java b/src/main/java/altk/comm/engine/Job.java index 4cd99e7..c1ccee7 100644 --- a/src/main/java/altk/comm/engine/Job.java +++ b/src/main/java/altk/comm/engine/Job.java @@ -74,4 +74,13 @@ public class Job return errorText; } + /** + * + * @return true to indicate that broadcast should abort. + */ + protected boolean isBroadcastFatal() + { + return false; + } + }