diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PullService.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PullService.java index 8dd9d279fb..aeb5a74b8b 100644 --- a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PullService.java +++ b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PullService.java @@ -55,7 +55,7 @@ public class PullService extends AbstractOfflineDetectorService implements IPull synchronized public RemoteNodeStatuses pullData() { RemoteNodeStatuses statuses = new RemoteNodeStatuses(); - Node identity = nodeService.findIdentity(); + Node identity = nodeService.findIdentity(false); if (identity == null || identity.isSyncEnabled()) { if (clusterService.lock(ClusterConstants.PULL)) { try { diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java index d0166578eb..482f1a4e0e 100644 --- a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java +++ b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java @@ -65,7 +65,7 @@ public class PushService extends AbstractOfflineDetectorService implements IPush synchronized public RemoteNodeStatuses pushData() { RemoteNodeStatuses statuses = new RemoteNodeStatuses(); - Node identity = nodeService.findIdentity(); + Node identity = nodeService.findIdentity(false); if (identity != null && identity.isSyncEnabled()) { if (clusterService.lock(ClusterConstants.PUSH)) { try {