org.jumpmind.symmetric.service

Interface INodeService

All Known Implementing Classes:

NodeService

public interface INodeService

This service provides an API to access Nodes and Node related information.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	INodeService.AuthenticationStatus

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 nodeId)
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 nodeId)
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)
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)
NodeStatus	getNodeStatus() Get the current status of this node.
NetworkedNode	getRootNetworkedNode()
void	ignoreNodeChannelForExternalId(boolean ignore, 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)
boolean	isDataLoadCompleted()
boolean	isDataLoadStarted()
boolean	isExternalIdRegistered(java.lang.String nodeGroupId, java.lang.String externalId)
boolean	isNodeAuthorized(java.lang.String nodeId, java.lang.String password)
boolean	isRegistrationEnabled(java.lang.String nodeId)
boolean	isRegistrationServer()
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)
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)
void	updateNodeHost(NodeHost nodeHost)
void	updateNodeHostForCurrentNode()
boolean	updateNodeSecurity(org.jumpmind.db.sql.ISqlTransaction transaction, NodeSecurity security)
boolean	updateNodeSecurity(NodeSecurity security)

Method Detail

findNode

Node findNode(java.lang.String nodeId)

findNode

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

findNodeInCacheOnly

Node findNodeInCacheOnly(java.lang.String id)

getExternalId

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

findNodeHosts

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

isRegistrationServer

boolean isRegistrationServer()

findNodeByExternalId

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

findNodesThatOriginatedFromNodeId

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).

findNodesThatOriginatedFromNodeId

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

findEnabledNodesFromNodeGroup

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

findNodesWithOpenRegistration

java.util.Collection<Node> findNodesWithOpenRegistration()

findAllNodeSecurity

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

findNodeSecurityWithLoadEnabled

java.util.List<NodeSecurity> findNodeSecurityWithLoadEnabled()

findAllExternalIds

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

findNodeSecurity

NodeSecurity findNodeSecurity(java.lang.String nodeId)

findNodeSecurity

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

findOrCreateNodeSecurity

NodeSecurity findOrCreateNodeSecurity(java.lang.String nodeId)

deleteNodeHost

void deleteNodeHost(java.lang.String nodeId)

deleteNodeSecurity

void deleteNodeSecurity(java.lang.String nodeId)

deleteNode

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

findSymmetricVersion

java.lang.String findSymmetricVersion()

findIdentityNodeId

java.lang.String findIdentityNodeId()

ignoreNodeChannelForExternalId

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

isNodeAuthorized

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

flushNodeCache

void flushNodeCache()

flushNodeAuthorizedCache

void flushNodeAuthorizedCache()

flushNodeGroupCache

void flushNodeGroupCache()

isRegistrationEnabled

boolean isRegistrationEnabled(java.lang.String nodeId)

findIdentity

Node findIdentity()

findIdentity

Node findIdentity(boolean useCache)

findIdentity

Node findIdentity(boolean useCache,
                  boolean logSqlError)

getCachedIdentity

Node getCachedIdentity()

deleteIdentity

boolean deleteIdentity()

findAllNodes

java.util.List<Node> findAllNodes()

findAllNodesAsMap

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

findNodesToPull

java.util.List<Node> findNodesToPull()

findNodesToPushTo

java.util.List<Node> findNodesToPushTo()

findNodesWhoPushToMe

java.util.List<Node> findNodesWhoPushToMe()

findNodesWhoPullFromMe

java.util.List<Node> findNodesWhoPullFromMe()

findSourceNodesFor

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

findTargetNodesFor

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

isExternalIdRegistered

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

save

void save(Node node)

updateNodeHost

void updateNodeHost(NodeHost nodeHost)

updateNodeHostForCurrentNode

void updateNodeHostForCurrentNode()

insertNodeIdentity

void insertNodeIdentity(java.lang.String nodeId)

insertNodeGroup

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

updateNodeSecurity

boolean updateNodeSecurity(NodeSecurity security)

updateNodeSecurity

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

setInitialLoadEnabled

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

setInitialLoadEnabled

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

setReverseInitialLoadEnabled

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

setReverseInitialLoadEnabled

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

isDataLoadCompleted

boolean isDataLoadCompleted()

Returns:

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

isDataLoadStarted

boolean isDataLoadStarted()

Returns:

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

getNodeStatus

NodeStatus getNodeStatus()

Get the current status of this node.

Returns:

NodeStatus

checkForOfflineNodes

void checkForOfflineNodes()

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

findOfflineNodes

java.util.List<Node> findOfflineNodes()

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

Returns:

list of offline nodes

findOfflineNodes

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

Find nodes that have been offline for a number of minutes

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

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

findOfflineNodeIds

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

getRootNetworkedNode

NetworkedNode getRootNetworkedNode()

findRootNode

Node findRootNode()

getAuthenticationStatus

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

resetNodeFailedLogins

void resetNodeFailedLogins(java.lang.String nodeId)

incrementNodeFailedLogins

void incrementNodeFailedLogins(java.lang.String nodeId)