0005421: Initial load won't start if registration_enabled is 1

JumpMind · Aug 24, 2022 · cce761d · cce761d
1 parent 90515ac
commit cce761d
Showing 1 changed file with 3 additions and 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
@@ -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) {