Package 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

Modifier and Type	Class	Description
static class	NodeService.NodeRowMapper

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	Description
NodeService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
protected String	buildOrderBy(String orderColumn, String orderDirection)
protected Map<String,Object>	buildParams(List<FilterCriterion> filter)
protected String	buildWhere(List<FilterCriterion> filter)
void	checkForOfflineNodes()	Check to see if any nodes are offline and process any nodes found using the configured IOfflineNodeHandler.
int	countFilteredNodes(List<FilterCriterion> filter)
boolean	deleteIdentity()
void	deleteNode(String nodeId, boolean syncChange)
void	deleteNode(String nodeId, String targetNodeId, boolean syncChange)
void	deleteNodeHost(String nodeId)
void	deleteNodeHostInstance(String nodeId, String instanceId)
void	deleteNodeSecurity(String nodeId)
List<String>	findAllExternalIds()
List<Node>	findAllNodes()
List<Node>	findAllNodes(boolean useCache)
Map<String,Node>	findAllNodesAsMap()
Map<String,NodeSecurity>	findAllNodeSecurity(boolean useCache)
Collection<Node>	findEnabledNodesFromNodeGroup(String nodeGroupId)
List<Node>	findFilteredNodesWithLimit(int offset, int limit, List<FilterCriterion> filter, String orderColumn, String orderDirection)
Node	findIdentity()
Node	findIdentity(boolean useCache)
Node	findIdentity(boolean useCache, boolean logSqlError)
String	findIdentityNodeId()
Map<String,Date>	findLastHeartbeats()
Node	findNode(String id)	Lookup a node in the database, which contains information for syncing with it.
Node	findNode(String id, boolean useCache)
Node	findNodeByExternalId(String nodeGroupId, String externalId)
List<NodeHost>	findNodeHosts(String nodeId)
Node	findNodeInCacheOnly(String id)
NodeSecurity	findNodeSecurity(String id)	Lookup a node_security in the database, which contains private information used to authenticate.
NodeSecurity	findNodeSecurity(String nodeId, boolean useCache)
List<NodeSecurity>	findNodeSecurityWithLoadEnabled()
Set<Node>	findNodesThatOriginatedFromNodeId(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).
Set<Node>	findNodesThatOriginatedFromNodeId(String originalNodeId, boolean recursive)
List<Node>	findNodesToPull()
List<Node>	findNodesToPushTo()
List<Node>	findNodesWhoPullFromMe()
List<Node>	findNodesWhoPushToMe()
Collection<Node>	findNodesWithOpenRegistration()
List<String>	findOfflineNodeIds(long minutesOffline)
List<Node>	findOfflineNodes()	Find nodes that have been offline for the configured timeframe before IOfflineClientListener and IOfflineServerListener will be called
List<Node>	findOfflineNodes(long minutesOffline)	Find nodes that have been offline for a number of minutes
NodeSecurity	findOrCreateNodeSecurity(String nodeId)
Node	findRootNode()
List<Node>	findSourceNodesFor(NodeGroupLinkAction eventAction)
String	findSymmetricVersion()
List<Node>	findTargetNodesFor(NodeGroupLinkAction eventAction)
protected void	fireOffline(List<Node> offlineClientNodeList)
void	flushNodeAuthorizedCache()
void	flushNodeCache()
void	flushNodeGroupCache()
INodeService.AuthenticationStatus	getAuthenticationStatus(String nodeId, String securityToken)
Node	getCachedIdentity()
Collection<Node>	getEnabledNodesFromDatabase()
String	getExternalId(String nodeId)
protected <T> T	getFirstEntry(List<T> list)
NodeStatus	getNodeStatus()	Get the current status of this node.
NodeStatus	getNodeStatus(String nodeId)
NetworkedNode	getRootNetworkedNode()
List<Node>	getSourceNodesFromDatabase(NodeGroupLinkAction eventAction, Node node)
List<Node>	getTargetNodesFromDatabase(NodeGroupLinkAction eventAction, Node node)
void	ignoreNodeChannelForExternalId(boolean enabled, String channelId, String nodeGroupId, String externalId)
void	incrementNodeFailedLogins(String nodeId)
void	insertNodeGroup(String groupId, String description)
void	insertNodeIdentity(String nodeId)
void	insertNodeSecurity(String id)
boolean	isDataLoadCompleted()
boolean	isDataLoadCompleted(String nodeId)
boolean	isDataLoadStarted()
boolean	isDataLoadStarted(String nodeId)
boolean	isExternalIdRegistered(String nodeGroupId, String externalId)
protected boolean	isNodeAuthorizationLocked(String nodeId)
boolean	isNodeAuthorized(String nodeId, String password)	Check that the given node and password match in the node_security table.
protected boolean	isNodePasswordFailedDecrypt(String nodeId)
boolean	isRegistrationEnabled(String nodeId)
boolean	isRegistrationServer()
protected boolean	registrationOpen(Node node)
void	resetNodeFailedLogins(String nodeId)
void	save(Node node)
boolean	setInitialLoadEnabled(String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, String createBy)
boolean	setInitialLoadEnabled(ISqlTransaction transaction, String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, String createBy)
boolean	setInitialLoadEnded(ISqlTransaction transaction, String nodeId)
void	setNodePasswordFilter(INodePasswordFilter nodePasswordFilter)
boolean	setPartialLoadEnded(ISqlTransaction transaction, String nodeId)
boolean	setPartialLoadStarted(ISqlTransaction transaction, String nodeId, long loadId, String createBy)
boolean	setReverseInitialLoadEnabled(String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, String createBy)
boolean	setReverseInitialLoadEnabled(ISqlTransaction transaction, String nodeId, boolean initialLoadEnabled, boolean syncChange, long loadId, String createBy)
protected boolean	syncEnabled(Node node)
boolean	updateNode(Node node)
void	updateNodeHost(NodeHost nodeHost)
void	updateNodeHostForCurrentNode()
boolean	updateNodeSecurity(ISqlTransaction transaction, NodeSecurity security)
boolean	updateNodeSecurity(NodeSecurity security)

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

assertNotNull, buildBatchOrderBy, buildBatchParams, buildBatchWhere, buildBatchWhereFromFilter, close, 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 Details

NodeService

public NodeService(ISymmetricEngine engine)

Method Details

findSymmetricVersion

public String findSymmetricVersion()

Specified by:

findSymmetricVersion in interface INodeService

findIdentityNodeId

public String findIdentityNodeId()

Specified by:

findIdentityNodeId in interface INodeService

getExternalId

public String getExternalId(String nodeId)

Specified by:

getExternalId in interface INodeService

findEnabledNodesFromNodeGroup

public Collection<Node> findEnabledNodesFromNodeGroup(String nodeGroupId)

Specified by:

findEnabledNodesFromNodeGroup in interface INodeService

getEnabledNodesFromDatabase

public Collection<Node> getEnabledNodesFromDatabase()

Specified by:

getEnabledNodesFromDatabase in interface INodeService

findNodesThatOriginatedFromNodeId

public Set<Node> findNodesThatOriginatedFromNodeId(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 Collection<Node> findNodesWithOpenRegistration()

Specified by:

findNodesWithOpenRegistration in interface INodeService

findNodesThatOriginatedFromNodeId

public Set<Node> findNodesThatOriginatedFromNodeId(String originalNodeId,
 boolean recursive)

Specified by:

findNodesThatOriginatedFromNodeId in interface INodeService

findNode

public Node findNode(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(String id)

Specified by:

findNodeInCacheOnly in interface INodeService

findNode

public Node findNode(String id,
 boolean useCache)

Specified by:

findNode in interface INodeService

flushNodeCache

public void flushNodeCache()

Specified by:

flushNodeCache in interface INodeService

findNodeByExternalId

public Node findNodeByExternalId(String nodeGroupId,
 String externalId)

Specified by:

findNodeByExternalId in interface INodeService

ignoreNodeChannelForExternalId

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

Specified by:

ignoreNodeChannelForExternalId in interface INodeService

findNodeHosts

public List<NodeHost> findNodeHosts(String nodeId)

Specified by:

findNodeHosts in interface INodeService

deleteNodeHost

public void deleteNodeHost(String nodeId)

Specified by:

deleteNodeHost in interface INodeService

deleteNodeHostInstance

public void deleteNodeHostInstance(String nodeId,
 String instanceId)

Specified by:

deleteNodeHostInstance 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(String nodeId,
 boolean syncChange)

Specified by:

deleteNode in interface INodeService

deleteNode

public void deleteNode(String nodeId,
 String targetNodeId,
 boolean syncChange)

Specified by:

deleteNode in interface INodeService

insertNodeIdentity

public void insertNodeIdentity(String nodeId)

Specified by:

insertNodeIdentity in interface INodeService

deleteIdentity

public boolean deleteIdentity()

Specified by:

deleteIdentity in interface INodeService

insertNodeGroup

public void insertNodeGroup(String groupId,
 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(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 List<Node> findNodesToPull()

Specified by:

findNodesToPull in interface INodeService

findNodesWhoPushToMe

public List<Node> findNodesWhoPushToMe()

Specified by:

findNodesWhoPushToMe in interface INodeService

findNodesToPushTo

public List<Node> findNodesToPushTo()

Specified by:

findNodesToPushTo in interface INodeService

findNodesWhoPullFromMe

public List<Node> findNodesWhoPullFromMe()

Specified by:

findNodesWhoPullFromMe in interface INodeService

findSourceNodesFor

public List<Node> findSourceNodesFor(NodeGroupLinkAction eventAction)

Specified by:

findSourceNodesFor in interface INodeService

getSourceNodesFromDatabase

public List<Node> getSourceNodesFromDatabase(NodeGroupLinkAction eventAction,
 Node node)

Specified by:

getSourceNodesFromDatabase in interface INodeService

findTargetNodesFor

public List<Node> findTargetNodesFor(NodeGroupLinkAction eventAction)

Specified by:

findTargetNodesFor in interface INodeService

getTargetNodesFromDatabase

public List<Node> getTargetNodesFromDatabase(NodeGroupLinkAction eventAction,
 Node node)

Specified by:

getTargetNodesFromDatabase in interface INodeService

flushNodeGroupCache

public void flushNodeGroupCache()

Specified by:

flushNodeGroupCache in interface INodeService

findAllExternalIds

public List<String> findAllExternalIds()

Specified by:

findAllExternalIds in interface INodeService

findAllNodes

public List<Node> findAllNodes()

Specified by:

findAllNodes in interface INodeService

findAllNodes

public List<Node> findAllNodes(boolean useCache)

Specified by:

findAllNodes in interface INodeService

findAllNodesAsMap

public Map<String,Node> findAllNodesAsMap()

Specified by:

findAllNodesAsMap in interface INodeService

findFilteredNodesWithLimit

public List<Node> findFilteredNodesWithLimit(int offset,
 int limit,
 List<FilterCriterion> filter,
 String orderColumn,
 String orderDirection)

Specified by:

findFilteredNodesWithLimit in interface INodeService

countFilteredNodes

public int countFilteredNodes(List<FilterCriterion> filter)

Specified by:

countFilteredNodes in interface INodeService

buildWhere

protected String buildWhere(List<FilterCriterion> filter)

buildParams

protected Map<String,Object> buildParams(List<FilterCriterion> filter)

buildOrderBy

protected String buildOrderBy(String orderColumn,
 String orderDirection)

getRootNetworkedNode

public NetworkedNode getRootNetworkedNode()

Specified by:

getRootNetworkedNode in interface INodeService

findRootNode

public Node findRootNode()

Specified by:

findRootNode in interface INodeService

findNodeSecurity

public NodeSecurity findNodeSecurity(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(String nodeId,
 boolean useCache)

Specified by:

findNodeSecurity in interface INodeService

findOrCreateNodeSecurity

public NodeSecurity findOrCreateNodeSecurity(String nodeId)

Specified by:

findOrCreateNodeSecurity in interface INodeService

isRegistrationEnabled

public boolean isRegistrationEnabled(String nodeId)

Specified by:

isRegistrationEnabled in interface INodeService

insertNodeSecurity

public void insertNodeSecurity(String id)

deleteNodeSecurity

public void deleteNodeSecurity(String nodeId)

Specified by:

deleteNodeSecurity in interface INodeService

findNodeSecurityWithLoadEnabled

public List<NodeSecurity> findNodeSecurityWithLoadEnabled()

Specified by:

findNodeSecurityWithLoadEnabled in interface INodeService

findAllNodeSecurity

public Map<String,NodeSecurity> findAllNodeSecurity(boolean useCache)

Specified by:

findAllNodeSecurity in interface INodeService

isNodeAuthorized

public boolean isNodeAuthorized(String nodeId,
 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(String nodeId)

isNodePasswordFailedDecrypt

protected boolean isNodePasswordFailedDecrypt(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(ISqlTransaction transaction,
 NodeSecurity security)

Specified by:

updateNodeSecurity in interface INodeService

setInitialLoadEnabled

public boolean setInitialLoadEnabled(ISqlTransaction transaction,
 String nodeId,
 boolean initialLoadEnabled,
 boolean syncChange,
 long loadId,
 String createBy)

Specified by:

setInitialLoadEnabled in interface INodeService

setInitialLoadEnabled

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

Specified by:

setInitialLoadEnabled in interface INodeService

setInitialLoadEnded

public boolean setInitialLoadEnded(ISqlTransaction transaction,
 String nodeId)

Specified by:

setInitialLoadEnded in interface INodeService

setPartialLoadStarted

public boolean setPartialLoadStarted(ISqlTransaction transaction,
 String nodeId,
 long loadId,
 String createBy)

Specified by:

setPartialLoadStarted in interface INodeService

setPartialLoadEnded

public boolean setPartialLoadEnded(ISqlTransaction transaction,
 String nodeId)

Specified by:

setPartialLoadEnded in interface INodeService

setReverseInitialLoadEnabled

public boolean setReverseInitialLoadEnabled(ISqlTransaction transaction,
 String nodeId,
 boolean initialLoadEnabled,
 boolean syncChange,
 long loadId,
 String createBy)

Specified by:

setReverseInitialLoadEnabled in interface INodeService

setReverseInitialLoadEnabled

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

Specified by:

setReverseInitialLoadEnabled in interface INodeService

isExternalIdRegistered

public boolean isExternalIdRegistered(String nodeGroupId,
 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.

isDataLoadCompleted

public boolean isDataLoadCompleted(String nodeId)

Specified by:

isDataLoadCompleted in interface INodeService

isDataLoadStarted

public boolean isDataLoadStarted()

Specified by:

isDataLoadStarted in interface INodeService

Returns:

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

isDataLoadStarted

public boolean isDataLoadStarted(String nodeId)

Specified by:

isDataLoadStarted in interface INodeService

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

getNodeStatus

public NodeStatus getNodeStatus(String nodeId)

Specified by:

getNodeStatus in interface INodeService

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 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 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 Map<String,Date> findLastHeartbeats()

Specified by:

findLastHeartbeats in interface INodeService

findOfflineNodeIds

public List<String> findOfflineNodeIds(long minutesOffline)

Specified by:

findOfflineNodeIds in interface INodeService

fireOffline

protected void fireOffline(List<Node> offlineClientNodeList)

getAuthenticationStatus

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

Specified by:

getAuthenticationStatus in interface INodeService

resetNodeFailedLogins

public void resetNodeFailedLogins(String nodeId)

Specified by:

resetNodeFailedLogins in interface INodeService

incrementNodeFailedLogins

public void incrementNodeFailedLogins(String nodeId)

Specified by:

incrementNodeFailedLogins in interface INodeService

syncEnabled

protected boolean syncEnabled(Node node)

registrationOpen

protected boolean registrationOpen(Node node)