0004187: Initial load queue and router service blocking each other

JumpMind · Dec 9, 2019 · 27a33d3 · 27a33d3
1 parent 3679cf9
commit 27a33d3
Showing 1 changed file with 5 additions and 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
@@ -258,7 +258,11 @@ public void insertOutgoingBatch(ISqlTransaction transaction, OutgoingBatch outgo
 
         long batchId = outgoingBatch.getBatchId();
         if (batchId <= 0) {
-            batchId = sequenceService.nextVal(Constants.SEQUENCE_OUTGOING_BATCH);
+            if (platform.supportsMultiThreadedTransactions()) {
+                batchId = sequenceService.nextVal(Constants.SEQUENCE_OUTGOING_BATCH);
+            } else {
+                batchId = sequenceService.nextVal(transaction, Constants.SEQUENCE_OUTGOING_BATCH);
+            }
         }
         transaction.prepareAndExecute(getSql("insertOutgoingBatchSql"), batchId, outgoingBatch.getNodeId(), outgoingBatch.getChannelId(),
                 outgoingBatch.getStatus().name(), outgoingBatch.getLoadId(), outgoingBatch.isExtractJobFlag() ? 1 : 0,