org.jumpmind.symmetric.service.impl

Class NodeService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.NodeService

All Implemented Interfaces:

INodeService, IService

public class NodeService
extends AbstractService
implements INodeService

See Also:

INodeService

Nested Class Summary

Nested classes/interfaces inherited from interface org.jumpmind.symmetric.service.INodeService

INodeService.AuthenticationStatus

Field Summary

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor and Description
NodeService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
void	checkForOfflineNodes() Check to see if any nodes are offline and process any nodes found using the configured IOfflineNodeHandler.
boolean	deleteIdentity()
void	deleteNode(java.lang.String nodeId, boolean syncChange)
void	deleteNodeHost(java.lang.String nodeId)
void	deleteNodeSecurity(java.lang.String nodeId)
java.util.List<java.lang.String>	findAllExternalIds()
java.util.List<Node>	findAllNodes()
java.util.Map<java.lang.String,Node>	findAllNodesAsMap()
java.util.Map<java.lang.String,NodeSecurity>	findAllNodeSecurity(boolean useCache)
java.util.Collection<Node>	findEnabledNodesFromNodeGroup(java.lang.String nodeGroupId)
Node	findIdentity()
Node	findIdentity(boolean useCache)
Node	findIdentity(boolean useCache, boolean logSqlError)
java.lang.String	findIdentityNodeId()
java.util.Map<java.lang.String,java.util.Date>	findLastHeartbeats()
Node	findNode(java.lang.String id) Lookup a node in the database, which contains information for syncing with it.
Node	findNode(java.lang.String id, boolean useCache)
Node	findNodeByExternalId(java.lang.String nodeGroupId, java.lang.String externalId)
java.util.List<NodeHost>	findNodeHosts(java.lang.String nodeId)
Node	findNodeInCacheOnly(java.lang.String id)
NodeSecurity	findNodeSecurity(java.lang.String id) Lookup a node_security in the database, which contains private information used to authenticate.
NodeSecurity	findNodeSecurity(java.lang.String nodeId, boolean useCache)
java.util.List<NodeSecurity>	findNodeSecurityWithLoadEnabled()
java.util.Set<Node>	findNodesThatOriginatedFromNodeId(java.lang.String originalNodeId) Find a list of Nodes that were create at the passed in node or were created at a node that was created by the passed in node (recursively).
java.util.Set<Node>	findNodesThatOriginatedFromNodeId(java.lang.String originalNodeId, boolean recursive)
java.util.List<Node>	findNodesToPull()
java.util.List<Node>	findNodesToPushTo()
java.util.List<Node>	findNodesWhoPullFromMe()
java.util.List<Node>	findNodesWhoPushToMe()
java.util.Collection<Node>	findNodesWithOpenRegistration()
java.util.List<java.lang.String>	findOfflineNodeIds(long minutesOffline)
java.util.List<Node>	findOfflineNodes() Find nodes that have been offline for the configured timeframe before IOfflineClientListener and IOfflineServerListener will be called
java.util.List<Node>	findOfflineNodes(long minutesOffline) Find nodes that have been offline for a number of minutes
NodeSecurity	findOrCreateNodeSecurity(java.lang.String nodeId)
Node	findRootNode()
java.util.List<Node>	findSourceNodesFor(NodeGroupLinkAction eventAction)
java.lang.String	findSymmetricVersion()
java.util.List<Node>	findTargetNodesFor(NodeGroupLinkAction eventAction)
protected void	fireOffline(java.util.List<Node> offlineClientNodeList)
void	flushNodeAuthorizedCache()
void	flushNodeCache()
void	flushNodeGroupCache()
INodeService.AuthenticationStatus	getAuthenticationStatus(java.lang.String nodeId, java.lang.String securityToken)
Node	getCachedIdentity()
java.lang.String	getExternalId(java.lang.String nodeId)
protected <T> T	getFirstEntry(java.util.List<T> list)
NodeStatus	getNodeStatus() Get the current status of this node.
NetworkedNode	getRootNetworkedNode()
void	ignoreNodeChannelForExternalId(boolean enabled, java.lang.String channelId, java.lang.String nodeGroupId, java.lang.String externalId)
void	incrementNodeFailedLogins(java.lang.String nodeId)
void	insertNodeGroup(java.lang.String groupId, java.lang.String description)
void	insertNodeIdentity(java.lang.String nodeId)
void	insertNodeSecurity(java.lang.String id)
boolean	isDataLoadCompleted()
boolean	isDataLoadStarted()
boolean	isExternalIdRegistered(java.lang.String nodeGroupId, java.lang.String externalId)
protected boolean	isNodeAuthorizationLocked(java.lang.String nodeId)
boolean	isNodeAuthorized(java.lang.String nodeId, java.lang.String password) Check that the given node and password match in the node_security table.
boolean	isRegistrationEnabled(java.lang.String nodeId)
boolean	isRegistrationServer()
protected boolean	registrationOpen(Node node)
void	resetNodeFailedLogins(java.lang.String nodeId)
void	save(Node node)
boolean	setInitialLoadEnabled(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, java.lang.String createBy)
boolean	setInitialLoadEnabled(java.lang.String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, java.lang.String createBy)
void	setNodePasswordFilter(INodePasswordFilter nodePasswordFilter)
boolean	setReverseInitialLoadEnabled(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, java.lang.String createBy)
boolean	setReverseInitialLoadEnabled(java.lang.String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, java.lang.String createBy)
protected boolean	syncEnabled(Node node)
boolean	updateNode(Node node)
void	updateNodeHost(NodeHost nodeHost)
void	updateNodeHostForCurrentNode()
boolean	updateNodeSecurity(org.jumpmind.db.sql.ISqlTransaction transaction, NodeSecurity security)
boolean	updateNodeSecurity(NodeSecurity security)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NodeService

public NodeService(ISymmetricEngine engine)

Method Detail

findSymmetricVersion

public java.lang.String findSymmetricVersion()

Specified by:

findSymmetricVersion in interface INodeService

findIdentityNodeId

public java.lang.String findIdentityNodeId()

Specified by:

findIdentityNodeId in interface INodeService

getExternalId

public java.lang.String getExternalId(java.lang.String nodeId)

Specified by:

getExternalId in interface INodeService

findEnabledNodesFromNodeGroup

public java.util.Collection<Node> findEnabledNodesFromNodeGroup(java.lang.String nodeGroupId)

Specified by:

findEnabledNodesFromNodeGroup in interface INodeService

findNodesThatOriginatedFromNodeId

public java.util.Set<Node> findNodesThatOriginatedFromNodeId(java.lang.String originalNodeId)

Description copied from interface: INodeService

Find a list of Nodes that were create at the passed in node or were created at a node that was created by the passed in node (recursively).

Specified by:

findNodesThatOriginatedFromNodeId in interface INodeService

findNodesWithOpenRegistration

public java.util.Collection<Node> findNodesWithOpenRegistration()

Specified by:

findNodesWithOpenRegistration in interface INodeService

findNodesThatOriginatedFromNodeId

public java.util.Set<Node> findNodesThatOriginatedFromNodeId(java.lang.String originalNodeId,
                                                             boolean recursive)

Specified by:

findNodesThatOriginatedFromNodeId in interface INodeService

findNode

public Node findNode(java.lang.String id)

Lookup a node in the database, which contains information for syncing with it.

Specified by:

findNode in interface INodeService

findNodeInCacheOnly

public Node findNodeInCacheOnly(java.lang.String id)

Specified by:

findNodeInCacheOnly in interface INodeService

findNode

public Node findNode(java.lang.String id,
                     boolean useCache)

Specified by:

findNode in interface INodeService

flushNodeCache

public void flushNodeCache()

Specified by:

flushNodeCache in interface INodeService

findNodeByExternalId

public Node findNodeByExternalId(java.lang.String nodeGroupId,
                                 java.lang.String externalId)

Specified by:

findNodeByExternalId in interface INodeService

ignoreNodeChannelForExternalId

public void ignoreNodeChannelForExternalId(boolean enabled,
                                           java.lang.String channelId,
                                           java.lang.String nodeGroupId,
                                           java.lang.String externalId)

Specified by:

ignoreNodeChannelForExternalId in interface INodeService

findNodeHosts

public java.util.List<NodeHost> findNodeHosts(java.lang.String nodeId)

Specified by:

findNodeHosts in interface INodeService

deleteNodeHost

public void deleteNodeHost(java.lang.String nodeId)

Specified by:

deleteNodeHost in interface INodeService

updateNodeHost

public void updateNodeHost(NodeHost nodeHost)

Specified by:

updateNodeHost in interface INodeService

updateNodeHostForCurrentNode

public void updateNodeHostForCurrentNode()

Specified by:

updateNodeHostForCurrentNode in interface INodeService

deleteNode

public void deleteNode(java.lang.String nodeId,
                       boolean syncChange)

Specified by:

deleteNode in interface INodeService

insertNodeIdentity

public void insertNodeIdentity(java.lang.String nodeId)

Specified by:

insertNodeIdentity in interface INodeService

deleteIdentity

public boolean deleteIdentity()

Specified by:

deleteIdentity in interface INodeService

insertNodeGroup

public void insertNodeGroup(java.lang.String groupId,
                            java.lang.String description)

Specified by:

insertNodeGroup in interface INodeService

save

public void save(Node node)

Specified by:

save in interface INodeService

updateNode

public boolean updateNode(Node node)

getFirstEntry

protected <T> T getFirstEntry(java.util.List<T> list)

getCachedIdentity

public Node getCachedIdentity()

Specified by:

getCachedIdentity in interface INodeService

findIdentity

public Node findIdentity()

Specified by:

findIdentity in interface INodeService

findIdentity

public Node findIdentity(boolean useCache)

Specified by:

findIdentity in interface INodeService

findIdentity

public Node findIdentity(boolean useCache,
                         boolean logSqlError)

Specified by:

findIdentity in interface INodeService

findNodesToPull

public java.util.List<Node> findNodesToPull()

Specified by:

findNodesToPull in interface INodeService

findNodesWhoPushToMe

public java.util.List<Node> findNodesWhoPushToMe()

Specified by:

findNodesWhoPushToMe in interface INodeService

findNodesToPushTo

public java.util.List<Node> findNodesToPushTo()

Specified by:

findNodesToPushTo in interface INodeService

findNodesWhoPullFromMe

public java.util.List<Node> findNodesWhoPullFromMe()

Specified by:

findNodesWhoPullFromMe in interface INodeService

findSourceNodesFor

public java.util.List<Node> findSourceNodesFor(NodeGroupLinkAction eventAction)

Specified by:

findSourceNodesFor in interface INodeService

findTargetNodesFor

public java.util.List<Node> findTargetNodesFor(NodeGroupLinkAction eventAction)

Specified by:

findTargetNodesFor in interface INodeService

flushNodeGroupCache

public void flushNodeGroupCache()

Specified by:

flushNodeGroupCache in interface INodeService

findAllExternalIds

public java.util.List<java.lang.String> findAllExternalIds()

Specified by:

findAllExternalIds in interface INodeService

findAllNodes

public java.util.List<Node> findAllNodes()

Specified by:

findAllNodes in interface INodeService

findAllNodesAsMap

public java.util.Map<java.lang.String,Node> findAllNodesAsMap()

Specified by:

findAllNodesAsMap in interface INodeService

getRootNetworkedNode

public NetworkedNode getRootNetworkedNode()

Specified by:

getRootNetworkedNode in interface INodeService

findRootNode

public Node findRootNode()

Specified by:

findRootNode in interface INodeService

findNodeSecurity

public NodeSecurity findNodeSecurity(java.lang.String id)

Lookup a node_security in the database, which contains private information used to authenticate.

Specified by:

findNodeSecurity in interface INodeService

findNodeSecurity

public NodeSecurity findNodeSecurity(java.lang.String nodeId,
                                     boolean useCache)

Specified by:

findNodeSecurity in interface INodeService

findOrCreateNodeSecurity

public NodeSecurity findOrCreateNodeSecurity(java.lang.String nodeId)

Specified by:

findOrCreateNodeSecurity in interface INodeService

isRegistrationEnabled

public boolean isRegistrationEnabled(java.lang.String nodeId)

Specified by:

isRegistrationEnabled in interface INodeService

insertNodeSecurity

public void insertNodeSecurity(java.lang.String id)

deleteNodeSecurity

public void deleteNodeSecurity(java.lang.String nodeId)

Specified by:

deleteNodeSecurity in interface INodeService

findNodeSecurityWithLoadEnabled

public java.util.List<NodeSecurity> findNodeSecurityWithLoadEnabled()

Specified by:

findNodeSecurityWithLoadEnabled in interface INodeService

findAllNodeSecurity

public java.util.Map<java.lang.String,NodeSecurity> findAllNodeSecurity(boolean useCache)

Specified by:

findAllNodeSecurity in interface INodeService

isNodeAuthorized

public boolean isNodeAuthorized(java.lang.String nodeId,
                                java.lang.String password)

Check that the given node and password match in the node_security table. A node must authenticate before it's allowed to sync data.

Specified by:

isNodeAuthorized in interface INodeService

isNodeAuthorizationLocked

protected boolean isNodeAuthorizationLocked(java.lang.String nodeId)

flushNodeAuthorizedCache

public void flushNodeAuthorizedCache()

Specified by:

flushNodeAuthorizedCache in interface INodeService

updateNodeSecurity

public boolean updateNodeSecurity(NodeSecurity security)

Specified by:

updateNodeSecurity in interface INodeService

updateNodeSecurity

public boolean updateNodeSecurity(org.jumpmind.db.sql.ISqlTransaction transaction,
                                  NodeSecurity security)

Specified by:

updateNodeSecurity in interface INodeService

setInitialLoadEnabled

public boolean setInitialLoadEnabled(org.jumpmind.db.sql.ISqlTransaction transaction,
                                     java.lang.String nodeId,
                                     boolean initialLoadEnabled,
                                     boolean syncChange,
                                     long loadId,
                                     java.lang.String createBy)

Specified by:

setInitialLoadEnabled in interface INodeService

setInitialLoadEnabled

public boolean setInitialLoadEnabled(java.lang.String nodeId,
                                     boolean initialLoadEnabled,
                                     boolean syncChange,
                                     long loadId,
                                     java.lang.String createBy)

Specified by:

setInitialLoadEnabled in interface INodeService

setReverseInitialLoadEnabled

public boolean setReverseInitialLoadEnabled(org.jumpmind.db.sql.ISqlTransaction transaction,
                                            java.lang.String nodeId,
                                            boolean initialLoadEnabled,
                                            boolean syncChange,
                                            long loadId,
                                            java.lang.String createBy)

Specified by:

setReverseInitialLoadEnabled in interface INodeService

setReverseInitialLoadEnabled

public boolean setReverseInitialLoadEnabled(java.lang.String nodeId,
                                            boolean initialLoadEnabled,
                                            boolean syncChange,
                                            long loadId,
                                            java.lang.String createBy)

Specified by:

setReverseInitialLoadEnabled in interface INodeService

isExternalIdRegistered

public boolean isExternalIdRegistered(java.lang.String nodeGroupId,
                                      java.lang.String externalId)

Specified by:

isExternalIdRegistered in interface INodeService

isDataLoadCompleted

public boolean isDataLoadCompleted()

Specified by:

isDataLoadCompleted in interface INodeService

Returns:

true if a data load has occurred and has been completed.

isDataLoadStarted

public boolean isDataLoadStarted()

Specified by:

isDataLoadStarted in interface INodeService

Returns:

true if a data load has started but not yet completed.

isRegistrationServer

public boolean isRegistrationServer()

Specified by:

isRegistrationServer in interface INodeService

getNodeStatus

public NodeStatus getNodeStatus()

Description copied from interface: INodeService

Get the current status of this node.

Specified by:

getNodeStatus in interface INodeService

Returns:

NodeStatus

setNodePasswordFilter

public void setNodePasswordFilter(INodePasswordFilter nodePasswordFilter)

checkForOfflineNodes

public void checkForOfflineNodes()

Description copied from interface: INodeService

Check to see if any nodes are offline and process any nodes found using the configured IOfflineNodeHandler.

Specified by:

checkForOfflineNodes in interface INodeService

findOfflineNodes

public java.util.List<Node> findOfflineNodes()

Description copied from interface: INodeService

Find nodes that have been offline for the configured timeframe before IOfflineClientListener and IOfflineServerListener will be called

Specified by:

findOfflineNodes in interface INodeService

Returns:

list of offline nodes

findOfflineNodes

public java.util.List<Node> findOfflineNodes(long minutesOffline)

Description copied from interface: INodeService

Find nodes that have been offline for a number of minutes

Specified by:

findOfflineNodes in interface INodeService

Parameters:

minutesOffline - the number of minutes that have passed that a node has not checked in for until it is considered offline

Returns:

list of offline nodes

findLastHeartbeats

public java.util.Map<java.lang.String,java.util.Date> findLastHeartbeats()

Specified by:

findLastHeartbeats in interface INodeService

findOfflineNodeIds

public java.util.List<java.lang.String> findOfflineNodeIds(long minutesOffline)

Specified by:

findOfflineNodeIds in interface INodeService

fireOffline

protected void fireOffline(java.util.List<Node> offlineClientNodeList)

getAuthenticationStatus

public INodeService.AuthenticationStatus getAuthenticationStatus(java.lang.String nodeId,
                                                                 java.lang.String securityToken)

Specified by:

getAuthenticationStatus in interface INodeService

resetNodeFailedLogins

public void resetNodeFailedLogins(java.lang.String nodeId)

Specified by:

resetNodeFailedLogins in interface INodeService

incrementNodeFailedLogins

public void incrementNodeFailedLogins(java.lang.String nodeId)

Specified by:

incrementNodeFailedLogins in interface INodeService

syncEnabled

protected boolean syncEnabled(Node node)

registrationOpen

protected boolean registrationOpen(Node node)