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