diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java index 8345e277de..aff3bf37c8 100644 --- a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java +++ b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java @@ -227,9 +227,9 @@ public boolean isInitialLoadComplete(String nodeId) { throw new RuntimeException("The initial load has not been started for " + nodeId); } for (String status : statuses) { - if (Status.ER.equals(status)) { + if (Status.ER.name().equals(status)) { throw new RuntimeException("The initial load errored out for " + nodeId); - } else if (Status.OK.equals(status)) { + } else if (Status.OK.name().equals(status)) { returnValue = true; } else { return false;