From 9055d74fc366c158478a0d718724d9f02edac353 Mon Sep 17 00:00:00 2001
From: ymlam <ymlam@link2tek.net>
Date: Tue, 30 May 2023 13:41:10 -0400
Subject: [PATCH] Fix bug of not updating activity count on exception

---
 src/main/java/altk/comm/engine/Broadcast.java | 2 ++
 1 file changed, 2 insertions(+)

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