From 2de021f28ff6bac879fe6b0a6cb4a964c70c8253 Mon Sep 17 00:00:00 2001 From: chenson42 Date: Tue, 31 Jan 2012 18:33:03 +0000 Subject: [PATCH] SYMMETRICDS-577 --- .../org/jumpmind/symmetric/model/OutgoingBatches.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/model/OutgoingBatches.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/model/OutgoingBatches.java index 388c4ae249..ba05f69d62 100644 --- a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/model/OutgoingBatches.java +++ b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/model/OutgoingBatches.java @@ -31,11 +31,9 @@ import java.util.Iterator; import java.util.List; import java.util.Set; - -import org.jumpmind.symmetric.model.OutgoingBatch.Status; /** - * + * A container for {@link OutgoingBatch}s. */ public class OutgoingBatches implements Serializable { @@ -99,7 +97,7 @@ public int countBatches(boolean includeOnlyErrors) { int count = 0; if (batches != null) { for (OutgoingBatch batch : batches) { - if (includeOnlyErrors && batch.getStatus() == OutgoingBatch.Status.ER) { + if (includeOnlyErrors && batch.isErrorFlag()) { count++; } else { count++; @@ -141,7 +139,7 @@ public boolean containsLoadBatches() { public boolean containsBatchesInError() { for (OutgoingBatch b : batches) { - if (b.getStatus() == Status.ER) { + if (b.isErrorFlag()) { return true; } } @@ -243,7 +241,7 @@ public void sortChannels(List channels) { final HashMap errorChannels = new HashMap(); for (OutgoingBatch batch : batches) { - if (batch.getStatus().equals(OutgoingBatch.Status.ER)) { + if (batch.isErrorFlag()) { errorChannels.put(batch.getChannelId(), batch.getLastUpdatedTime()); } }