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;
+	}
+
 }