From 3106b741d7e8a5f3855c92a8506981bf731929ec Mon Sep 17 00:00:00 2001 From: Philip Marzullo Date: Tue, 2 May 2023 12:36:25 -0400 Subject: [PATCH] 0005819: OutgoingBatchService loadPendingBatches should use read uncommitted to minimize deadlocking possibilities --- .../jumpmind/symmetric/service/impl/OutgoingBatchService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 c415f80a9d..883e815321 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 @@ -562,7 +562,7 @@ public OutgoingBatches getOutgoingBatches(String nodeId, String channelThread, N types = new int[] { Types.VARCHAR, Types.CHAR, Types.CHAR, Types.CHAR, Types.CHAR, Types.CHAR, Types.CHAR, Types.CHAR, Types.CHAR }; } - List list = (List) sqlTemplate.query(sql, maxNumberOfBatchesToSelect, + List list = (List) sqlTemplateDirty.query(sql, maxNumberOfBatchesToSelect, new OutgoingBatchMapper(includeDisabledChannels), params, types); OutgoingBatches batches = new OutgoingBatches(list); List channels = new ArrayList(configurationService.getNodeChannels(nodeId, true));