diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/monitor/MonitorTypeBatchError.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/monitor/MonitorTypeBatchError.java
index faf09309e9..91c5bf1499 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/monitor/MonitorTypeBatchError.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/monitor/MonitorTypeBatchError.java
@@ -60,21 +60,15 @@ public MonitorEvent check(Monitor monitor) {
         
         OutgoingBatches outgoingBatches = outgoingBatchService.getOutgoingBatchErrors(1000);
         for (OutgoingBatch batch : outgoingBatches.getBatches()) {
-            int batchErrorMinutes = (int) (System.currentTimeMillis() - batch.getCreateTime().getTime()) / 60000;
-            if (batchErrorMinutes >= monitor.getThreshold()) {
-                outgoingErrorCount++;
-                outgoingErrors.add(batch);
-            }
+            outgoingErrorCount++;
+            outgoingErrors.add(batch);
         }
 
         int incomingErrorCount = 0;
         List<IncomingBatch> incomingBatches = incomingBatchService.findIncomingBatchErrors(1000);
         for (IncomingBatch batch : incomingBatches) {
-            int batchErrorMinutes = (int) (System.currentTimeMillis() - batch.getCreateTime().getTime()) / 60000;
-            if (batchErrorMinutes >= monitor.getThreshold()) {
-                incomingErrorCount++;
-                incomingErrors.add(batch);
-            }
+            incomingErrorCount++;
+            incomingErrors.add(batch);
         }
 
         event.setValue(outgoingErrorCount + incomingErrorCount);