0006223: Fixed imported configuration being deleted from sym_data

JumpMind · Feb 5, 2024 · 6ace631 · 6ace631
1 parent 609ba7d
commit 6ace631
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...c-core/src/main/java/org/jumpmind/symmetric/service/impl/ManageIncomingBatchListener.java b/...c-core/src/main/java/org/jumpmind/symmetric/service/impl/ManageIncomingBatchListener.java
@@ -103,7 +103,7 @@ public boolean beforeBatchStarted(DataContext context) {
         if (parameterService.is(ParameterConstants.DATA_LOADER_ENABLED)
                 || (batch.getChannelId() != null && batch.getChannelId().equals(
                         Constants.CHANNEL_CONFIG))) {
-            if (batch.getBatchId() == Constants.VIRTUAL_BATCH_FOR_REGISTRATION) {
+            if (batch.getBatchId() == Constants.VIRTUAL_BATCH_FOR_REGISTRATION && batch.getSourceNodeId() != null) {
                 log.info("Preparing to receive registration from node {} by clearing its outgoing config batches", batch.getSourceNodeId());
                 IOutgoingBatchService outgoingBatchService = engine.getOutgoingBatchService();
                 IDataService dataService = engine.getDataService();