diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java
index a2cec366ac..5f4f38d0e1 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java
@@ -147,7 +147,7 @@ public void updateAbandonedRoutingBatches() {
         int count = sqlTemplate.queryForInt(getSql("countOutgoingBatchesWithStatusSql"), Status.RT.name());
         if (count > 0) {
             log.info("Cleaning up {} batches that were abandoned by a failed or aborted attempt at routing", count);
-            sqlTemplate.update(getSql("updateOutgoingBatchesStatusSql"), Status.NE.name(),
+            sqlTemplate.update(getSql("updateOutgoingBatchesStatusSql"), Status.OK.name(),
                     Status.RT.name());
         }
     }