clean up abandoned RT batches

JumpMind · Mar 2, 2012 · 604bc85 · 604bc85
1 parent fed8842
commit 604bc85
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...etric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java b/...etric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java
@@ -191,6 +191,7 @@ synchronized public long routeData() {
         long dataCount = -1l;
         if (clusterService.lock(ClusterConstants.ROUTE)) {
             try {
+                outgoingBatchService.updateAbandonedRoutingBatches();
                 insertInitialLoadEvents();
                 long ts = System.currentTimeMillis();
                 IDataToRouteGapDetector gapDetector = new DataGapDetector(dataService,