diff --git a/src/main/java/altk/comm/engine/Broadcast.java b/src/main/java/altk/comm/engine/Broadcast.java
index 893e233..1d73949 100644
--- a/src/main/java/altk/comm/engine/Broadcast.java
+++ b/src/main/java/altk/comm/engine/Broadcast.java
@@ -375,12 +375,14 @@ public abstract class Broadcast
                 {
                 	// Aborting
                     setState(BroadcastState.ABORTING, e.errorCodeText, e.errorText);
+                    updateServiceActivityCount(-batch.size());
                 }
                 catch (Throwable t)
                 {
                     // This is unexpected. Log stack trace
                     myLogger.error("Caught unexpected Throwable", t);
                     terminate(BroadcastState.ABORTED, t + ": " + t.getMessage());
+                    updateServiceActivityCount(-batch.size());
                 }
                 if (sleepBetweenJobs > 0)
                 {