From f705488c9a693dfb2e38667d1c87f6bf54760486 Mon Sep 17 00:00:00 2001 From: Eric Long Date: Tue, 3 Dec 2019 12:35:28 -0500 Subject: [PATCH] 0004175: Node communication query for unsent batches not using index on Oracle --- .../symmetric/service/impl/NodeCommunicationService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java index b8b20cf02c..7c11262cc5 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java @@ -251,8 +251,8 @@ public List list(CommunicationType communicationType) { protected List getNodeIdsWithUnsentCount() { return sqlTemplate.query(getSql("selectNodeIdsWithUnsentBatchsSql"), - new StringMapper(), OutgoingBatch.Status.ER, OutgoingBatch.Status.NE, OutgoingBatch.Status.QY, - OutgoingBatch.Status.SE, OutgoingBatch.Status.LD, OutgoingBatch.Status.IG, OutgoingBatch.Status.RS); + new StringMapper(), OutgoingBatch.Status.ER.name(), OutgoingBatch.Status.NE.name(), OutgoingBatch.Status.QY.name(), + OutgoingBatch.Status.SE.name(), OutgoingBatch.Status.LD.name(), OutgoingBatch.Status.IG.name(), OutgoingBatch.Status.RS.name()); } protected List filterForChannelThreading(List nodesToCommunicateWith) {