diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/FileSyncService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/FileSyncService.java index 94dcc5ce4d..bbe657475a 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/FileSyncService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/FileSyncService.java @@ -919,7 +919,7 @@ protected void pullFilesFromNode(NodeCommunication nodeCommunication, RemoteNode protected RemoteNodeStatuses queueJob(boolean force, long minimumPeriodMs, String clusterLock, CommunicationType type) { final RemoteNodeStatuses statuses = new RemoteNodeStatuses(engine.getConfigurationService().getChannels(false)); - Node identity = engine.getNodeService().findIdentity(false); + Node identity = engine.getNodeService().findIdentity(); if (identity != null && identity.isSyncEnabled()) { if (force || !engine.getClusterService().isInfiniteLocked(clusterLock)) { diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OfflinePullService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OfflinePullService.java index b12e880576..463bdd742d 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OfflinePullService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OfflinePullService.java @@ -73,7 +73,7 @@ public OfflinePullService(IParameterService parameterService, ISymmetricDialect synchronized public RemoteNodeStatuses pullData(boolean force) { RemoteNodeStatuses statuses = new RemoteNodeStatuses(configurationService.getChannels(false)); - Node identity = nodeService.findIdentity(false); + Node identity = nodeService.findIdentity(); if (identity != null && identity.isSyncEnabled()) { if (force || !clusterService.isInfiniteLocked(ClusterConstants.OFFLINE_PULL)) { List nodes = nodeCommunicationService.list(CommunicationType.OFFLN_PULL); diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OfflinePushService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OfflinePushService.java index bbb474c394..738614874e 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OfflinePushService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OfflinePushService.java @@ -88,7 +88,7 @@ public OfflinePushService(IParameterService parameterService, ISymmetricDialect synchronized public RemoteNodeStatuses pushData(boolean force) { RemoteNodeStatuses statuses = new RemoteNodeStatuses(configurationService.getChannels(false)); - Node identity = nodeService.findIdentity(false); + Node identity = nodeService.findIdentity(); if (identity != null && identity.isSyncEnabled()) { if (force || !clusterService.isInfiniteLocked(ClusterConstants.OFFLINE_PUSH)) { List nodes = nodeCommunicationService.list(CommunicationType.OFFLN_PUSH); @@ -127,7 +127,7 @@ public void execute(NodeCommunication nodeCommunication, RemoteNodeStatus status } private void pushToNode(Node remote, RemoteNodeStatus status) { - Node identity = nodeService.findIdentity(false); + Node identity = nodeService.findIdentity(); FileOutgoingTransport transport = null; ProcessInfo processInfo = statisticManager.newProcessInfo(new ProcessInfoKey( identity.getNodeId(), status.getChannelId(), remote.getNodeId(), ProcessType.OFFLINE_PUSH)); diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PullService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PullService.java index 7e464874a2..883e5caffe 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PullService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PullService.java @@ -80,13 +80,13 @@ public PullService(IParameterService parameterService, ISymmetricDialect symmetr synchronized public RemoteNodeStatuses pullData(boolean force) { final RemoteNodeStatuses statuses = new RemoteNodeStatuses(configurationService.getChannels(false)); - Node identity = nodeService.findIdentity(false); + Node identity = nodeService.findIdentity(); if (identity == null || identity.isSyncEnabled()) { long minimumPeriodMs = parameterService.getLong(ParameterConstants.PULL_MINIMUM_PERIOD_MS, -1); if (force || !clusterService.isInfiniteLocked(ClusterConstants.PULL)) { // register if we haven't already been registered registrationService.registerWithServer(); - identity = nodeService.findIdentity(false); + identity = nodeService.findIdentity(); if (identity != null) { List nodes = nodeCommunicationService .list(CommunicationType.PULL); diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java index 4e077aa38b..3dce663c52 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java @@ -103,7 +103,7 @@ public Map getStartTimesOfNodesBeingPushedTo() { synchronized public RemoteNodeStatuses pushData(boolean force) { RemoteNodeStatuses statuses = new RemoteNodeStatuses(configurationService.getChannels(false)); - Node identity = nodeService.findIdentity(false); + Node identity = nodeService.findIdentity(); if (identity != null && identity.isSyncEnabled()) { long minimumPeriodMs = parameterService.getLong(ParameterConstants.PUSH_MINIMUM_PERIOD_MS, -1); if (force || !clusterService.isInfiniteLocked(ClusterConstants.PUSH)) { @@ -186,7 +186,7 @@ public void execute(NodeCommunication nodeCommunication, RemoteNodeStatus status } private void pushToNode(Node remote, RemoteNodeStatus status) { - Node identity = nodeService.findIdentity(false); + Node identity = nodeService.findIdentity(); NodeSecurity identitySecurity = nodeService.findNodeSecurity(identity.getNodeId()); IOutgoingWithResponseTransport transport = null; ProcessInfo processInfo = statisticManager.newProcessInfo(new ProcessInfoKey(identity diff --git a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/rest/RestService.java b/symmetric-server/src/main/java/org/jumpmind/symmetric/web/rest/RestService.java index 9118d8e864..8e2cc99ada 100644 --- a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/rest/RestService.java +++ b/symmetric-server/src/main/java/org/jumpmind/symmetric/web/rest/RestService.java @@ -1516,7 +1516,7 @@ private Node nodeImpl(ISymmetricEngine engine) { Node xmlNode = new Node(); if (isRegistered(engine)) { INodeService nodeService = engine.getNodeService(); - org.jumpmind.symmetric.model.Node modelNode = nodeService.findIdentity(false); + org.jumpmind.symmetric.model.Node modelNode = nodeService.findIdentity(); List nodeHosts = nodeService.findNodeHosts(modelNode.getNodeId()); NodeSecurity nodeSecurity = nodeService.findNodeSecurity(modelNode.getNodeId()); xmlNode.setNodeId(modelNode.getNodeId()); @@ -1559,7 +1559,7 @@ private boolean isRootNode(ISymmetricEngine engine, org.jumpmind.symmetric.model private boolean isRegistered(ISymmetricEngine engine) { boolean registered = true; INodeService nodeService = engine.getNodeService(); - org.jumpmind.symmetric.model.Node modelNode = nodeService.findIdentity(false); + org.jumpmind.symmetric.model.Node modelNode = nodeService.findIdentity(); if (modelNode == null) { registered = false; } else { @@ -1576,7 +1576,7 @@ private NodeStatus nodeStatusImpl(ISymmetricEngine engine) { NodeStatus status = new NodeStatus(); if (isRegistered(engine)) { INodeService nodeService = engine.getNodeService(); - org.jumpmind.symmetric.model.Node modelNode = nodeService.findIdentity(false); + org.jumpmind.symmetric.model.Node modelNode = nodeService.findIdentity(); NodeSecurity nodeSecurity = nodeService.findNodeSecurity(modelNode.getNodeId()); List nodeHost = nodeService.findNodeHosts(modelNode.getNodeId()); status.setStarted(engine.isStarted());