From cce761d448e3b0ce48ff86b336377dd98406b827 Mon Sep 17 00:00:00 2001
From: Eric Long <elong@jumpmind.com>
Date: Wed, 24 Aug 2022 14:43:13 -0400
Subject: [PATCH] 0005421: Initial load won't start if registration_enabled is
 1

---
 .../service/impl/InitialLoadService.java         | 16 +++-------------
 1 file changed, 3 insertions(+), 13 deletions(-)

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/InitialLoadService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/InitialLoadService.java
index 11a39d2ee0..c2c65fb915 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/InitialLoadService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/InitialLoadService.java
@@ -70,25 +70,15 @@ public InitialLoadService(ISymmetricEngine engine) {
     @Override
     public synchronized void queueLoads(boolean force) {
         Node identity = engine.getNodeService().findIdentity();
-        if (identity != null) {
+        if (identity != null && identity.isSyncEnabled()) {
             if (force || engine.getClusterService().lock(ClusterConstants.INITIAL_LOAD_QUEUE)) {
                 ProcessInfo processInfo = null;
                 try {
                     processInfo = engine.getStatisticManager().newProcessInfo(
                             new ProcessInfoKey(identity.getNodeId(), null, ProcessType.INSERT_LOAD_EVENTS));
                     processInfo.setStatus(ProcessInfo.ProcessStatus.PROCESSING);
-                    boolean isRegistered = false;
-                    if (engine.getParameterService().isRegistrationServer()) {
-                        isRegistered = true;
-                    } else {
-                        boolean isClusteringEnabled = parameterService.is(ParameterConstants.CLUSTER_LOCKING_ENABLED);
-                        NodeSecurity identitySecurity = engine.getNodeService().findNodeSecurity(identity.getNodeId(), !isClusteringEnabled);
-                        isRegistered = identitySecurity != null && identitySecurity.hasRegistered();
-                    }
-                    if (isRegistered) {
-                        processInitialLoadEnabledFlag(identity, processInfo);
-                        processTableRequestLoads(identity, processInfo);
-                    }
+                    processInitialLoadEnabledFlag(identity, processInfo);
+                    processTableRequestLoads(identity, processInfo);
                     processInfo.setStatus(ProcessInfo.ProcessStatus.OK);
                 } catch (Exception e) {
                     if (processInfo != null) {