Package org.jumpmind.symmetric.service.impl

Class MockNodeService

java.lang.Object

org.jumpmind.symmetric.service.impl.MockNodeService

All Implemented Interfaces:

INodeService

public class MockNodeService
extends Object
implements INodeService

Nested Class Summary

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

INodeService.AuthenticationStatus

Constructor Summary

Constructors

Constructor	Description
MockNodeService()

Method Summary

Modifier and Type	Method	Description
void	addOfflineServerListener(IOfflineServerListener listener)
void	checkForOfflineNodes()	Check to see if any nodes are offline and process any nodes found using the configured IOfflineNodeHandler.
void	clearCache()
int	countFilteredNodes(List<FilterCriterion> filter)
boolean	deleteIdentity()
void	deleteNode(String nodeId, boolean syncChange)
void	deleteNode(String myNodeId, String targetNodeIId, 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 nodeId)
Node	findNode(String id, boolean useCache)
Node	findNodeByExternalId(String nodeGroupId, String externalId)
List<NodeHost>	findNodeHosts(String nodeId)
Node	findNodeInCacheOnly(String id)
NodeSecurity	findNodeSecurity(String nodeId)
NodeSecurity	findNodeSecurity(String nodeId, boolean createIfNotFound)
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)
void	flushNodeAuthorizedCache()
void	flushNodeCache()
void	flushNodeGroupCache()
String	generateNodeId(String nodeGroupId, String externalId)
String	generatePassword()
INodeService.AuthenticationStatus	getAuthenticationStatus(String nodeId, String securityToken)
Node	getCachedIdentity()
Collection<Node>	getEnabledNodesFromDatabase()
String	getExternalId(String nodeId)
INodeIdCreator	getNodeIdCreator()
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 ignore, String channelId, String nodeGroupId, String externalId)
void	incrementNodeFailedLogins(String nodeId)
void	insertNodeGroup(String groupId, String description)
void	insertNodeIdentity(String nodeId)
boolean	isDataLoadCompleted()
boolean	isDataLoadCompleted(String nodeId)
boolean	isDataLoadStarted()
boolean	isDataLoadStarted(String nodeId)
boolean	isExternalIdRegistered(String nodeGroupId, String externalId)
boolean	isNodeAuthorized(String nodeId, String password)
boolean	isRegistrationEnabled(String nodeId)
boolean	isRegistrationServer()
boolean	removeOfflineServerListener(IOfflineServerListener listener)
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	setNodeIdCreator(INodeIdCreator nodeIdGenerator)
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)
boolean	updateNode(Node node)
void	updateNodeHost(NodeHost nodeHost)
void	updateNodeHostForCurrentNode()
boolean	updateNodeSecurity(ISqlTransaction transaction, NodeSecurity security)
boolean	updateNodeSecurity(NodeSecurity security)

Methods inherited from class java.lang.Object

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

Constructor Details

MockNodeService

public MockNodeService()

Method Details

getCachedIdentity

public Node getCachedIdentity()

Specified by:

getCachedIdentity 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

findNodesWhoPushToMe

public List<Node> findNodesWhoPushToMe()

Specified by:

findNodesWhoPushToMe in interface INodeService

findNodesWhoPullFromMe

public List<Node> findNodesWhoPullFromMe()

Specified by:

findNodesWhoPullFromMe in interface INodeService

findAllNodesAsMap

public Map<String,Node> findAllNodesAsMap()

Specified by:

findAllNodesAsMap in interface INodeService

deleteNodeHost

public void deleteNodeHost(String nodeId)

Specified by:

deleteNodeHost in interface INodeService

deleteNode

public void deleteNode(String nodeId,
 boolean syncChange)

Specified by:

deleteNode in interface INodeService

deleteNode

public void deleteNode(String myNodeId,
 String targetNodeIId,
 boolean syncChange)

Specified by:

deleteNode in interface INodeService

findAllExternalIds

public List<String> findAllExternalIds()

Specified by:

findAllExternalIds in interface INodeService

getRootNetworkedNode

public NetworkedNode getRootNetworkedNode()

Specified by:

getRootNetworkedNode in interface INodeService

findOfflineNodeIds

public List<String> findOfflineNodeIds(long minutesOffline)

Specified by:

findOfflineNodeIds in interface INodeService

isRegistrationServer

public boolean isRegistrationServer()

Specified by:

isRegistrationServer 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

findNodesThatOriginatedFromNodeId

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

Specified by:

findNodesThatOriginatedFromNodeId in interface INodeService

findNodesWithOpenRegistration

public Collection<Node> findNodesWithOpenRegistration()

Specified by:

findNodesWithOpenRegistration in interface INodeService

findNodeHosts

public List<NodeHost> findNodeHosts(String nodeId)

Specified by:

findNodeHosts in interface INodeService

findIdentity

public Node findIdentity()

Specified by:

findIdentity 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

findAllNodeSecurity

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

Specified by:

findAllNodeSecurity in interface INodeService

findSymmetricVersion

public String findSymmetricVersion()

Specified by:

findSymmetricVersion in interface INodeService

findNodeSecurity

public NodeSecurity findNodeSecurity(String nodeId,
 boolean createIfNotFound)

Specified by:

findNodeSecurity in interface INodeService

save

public void save(Node node)

Specified by:

save in interface INodeService

updateNodeHostForCurrentNode

public void updateNodeHostForCurrentNode()

Specified by:

updateNodeHostForCurrentNode in interface INodeService

insertNodeGroup

public void insertNodeGroup(String groupId,
 String description)

Specified by:

insertNodeGroup in interface INodeService

insertNodeIdentity

public void insertNodeIdentity(String nodeId)

Specified by:

insertNodeIdentity in interface INodeService

findIdentityNodeId

public String findIdentityNodeId()

Specified by:

findIdentityNodeId in interface INodeService

findNode

public Node findNode(String nodeId)

Specified by:

findNode in interface INodeService

findNodeInCacheOnly

public Node findNodeInCacheOnly(String id)

Specified by:

findNodeInCacheOnly 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

findNodeByExternalId

public Node findNodeByExternalId(String nodeGroupId,
 String externalId)

Specified by:

findNodeByExternalId in interface INodeService

findNodeSecurity

public NodeSecurity findNodeSecurity(String nodeId)

Specified by:

findNodeSecurity in interface INodeService

findNodesToPull

public List<Node> findNodesToPull()

Specified by:

findNodesToPull in interface INodeService

findNodesToPushTo

public List<Node> findNodesToPushTo()

Specified by:

findNodesToPushTo in interface INodeService

findSourceNodesFor

public List<Node> findSourceNodesFor(NodeGroupLinkAction eventAction)

Specified by:

findSourceNodesFor in interface INodeService

findTargetNodesFor

public List<Node> findTargetNodesFor(NodeGroupLinkAction eventAction)

Specified by:

findTargetNodesFor in interface INodeService

getSourceNodesFromDatabase

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

Specified by:

getSourceNodesFromDatabase in interface INodeService

getTargetNodesFromDatabase

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

Specified by:

getTargetNodesFromDatabase in interface INodeService

ignoreNodeChannelForExternalId

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

Specified by:

ignoreNodeChannelForExternalId in interface INodeService

isExternalIdRegistered

public boolean isExternalIdRegistered(String nodeGroupId,
 String externalId)

Specified by:

isExternalIdRegistered in interface INodeService

isNodeAuthorized

public boolean isNodeAuthorized(String nodeId,
 String password)

Specified by:

isNodeAuthorized in interface INodeService

isRegistrationEnabled

public boolean isRegistrationEnabled(String nodeId)

Specified by:

isRegistrationEnabled in interface INodeService

setInitialLoadEnabled

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

Specified by:

setInitialLoadEnabled 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

updateNode

public boolean updateNode(Node node)

updateNodeSecurity

public boolean updateNodeSecurity(ISqlTransaction transaction,
 NodeSecurity security)

Specified by:

updateNodeSecurity in interface INodeService

updateNodeSecurity

public boolean updateNodeSecurity(NodeSecurity security)

Specified by:

updateNodeSecurity in interface INodeService

findIdentity

public Node findIdentity(boolean useCache)

Specified by:

findIdentity in interface INodeService

generateNodeId

public String generateNodeId(String nodeGroupId,
 String externalId)

generatePassword

public String generatePassword()

flushNodeAuthorizedCache

public void flushNodeAuthorizedCache()

Specified by:

flushNodeAuthorizedCache in interface INodeService

getNodeIdCreator

public INodeIdCreator getNodeIdCreator()

setNodeIdCreator

public void setNodeIdCreator(INodeIdCreator nodeIdGenerator)

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.

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

deleteIdentity

public boolean deleteIdentity()

Specified by:

deleteIdentity in interface INodeService

deleteNodeSecurity

public void deleteNodeSecurity(String nodeId)

Specified by:

deleteNodeSecurity in interface INodeService

addOfflineServerListener

public void addOfflineServerListener(IOfflineServerListener listener)

removeOfflineServerListener

public boolean removeOfflineServerListener(IOfflineServerListener listener)

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

findNodeSecurityWithLoadEnabled

public List<NodeSecurity> findNodeSecurityWithLoadEnabled()

Specified by:

findNodeSecurityWithLoadEnabled in interface INodeService

findOrCreateNodeSecurity

public NodeSecurity findOrCreateNodeSecurity(String nodeId)

Specified by:

findOrCreateNodeSecurity in interface INodeService

findIdentity

public Node findIdentity(boolean useCache,
 boolean logSqlError)

Specified by:

findIdentity in interface INodeService

updateNodeHost

public void updateNodeHost(NodeHost nodeHost)

Specified by:

updateNodeHost in interface INodeService

findLastHeartbeats

public Map<String,Date> findLastHeartbeats()

Specified by:

findLastHeartbeats in interface INodeService

clearCache

public void clearCache()

flushNodeGroupCache

public void flushNodeGroupCache()

Specified by:

flushNodeGroupCache in interface INodeService

getExternalId

public String getExternalId(String nodeId)

Specified by:

getExternalId in interface INodeService

flushNodeCache

public void flushNodeCache()

Specified by:

flushNodeCache in interface INodeService

findNode

public Node findNode(String id,
 boolean useCache)

Specified by:

findNode in interface INodeService

getAuthenticationStatus

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

Specified by:

getAuthenticationStatus in interface INodeService

findRootNode

public Node findRootNode()

Specified by:

findRootNode 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

isDataLoadCompleted

public boolean isDataLoadCompleted(String nodeId)

Specified by:

isDataLoadCompleted in interface INodeService

isDataLoadStarted

public boolean isDataLoadStarted(String nodeId)

Specified by:

isDataLoadStarted in interface INodeService

getNodeStatus

public NodeStatus getNodeStatus(String nodeId)

Specified by:

getNodeStatus 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

deleteNodeHostInstance

public void deleteNodeHostInstance(String nodeId,
 String instanceId)

Specified by:

deleteNodeHostInstance in interface INodeService