com.atlassian.jira.cluster

Class OfBizClusterNodeStore

java.lang.Object

com.atlassian.jira.cluster.OfBizClusterNodeStore

public class OfBizClusterNodeStore
extends Object

Responsible for storing and retrieving ClusterNode state in the underlying database

Since:

v6.1

Constructor Summary

Constructors

Constructor and Description
OfBizClusterNodeStore(OfBizDelegator ofBizDelegator)

Method Summary

Modifier and Type	Method and Description
Node	createNode(String nodeId, Node.NodeState state, String ip, Long cacheListenerPort, Long nodeBuildNumber, String nodeVersion) Creates the node in the underlying database.
int	deleteNode(Node node) Deletes the node from the underlying database.
List<Node>	findNodes(org.ofbiz.core.entity.EntityCondition condition, List<String> orderBy)
List<Node>	getAllNodes()
Node	getNode(String nodeId)
Node	updateNode(String nodeId, Node.NodeState state, String ip, Long cacheListenerPort, Long nodeBuildNumber, String nodeVersion) Stores the node in the underlying database.

Methods inherited from class java.lang.Object

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

Constructor Detail

OfBizClusterNodeStore

public OfBizClusterNodeStore(OfBizDelegator ofBizDelegator)

Method Detail

createNode

public Node createNode(@Nonnull
                       String nodeId,
                       @Nonnull
                       Node.NodeState state,
                       @Nonnull
                       String ip,
                       @Nonnull
                       Long cacheListenerPort,
                       @Nonnull
                       Long nodeBuildNumber,
                       String nodeVersion)

Creates the node in the underlying database.

Parameters:

nodeId - - the node id to create and store in the underlying table

state - - the desired node state

cacheListenerPort - the multicast port the server is going to use to listen for changes

nodeBuildNumber - build number of the code the node is running

nodeVersion -

Returns:

the newly created node

Throws:

DataAccessException - if a database error prevents the node from being created

updateNode

public Node updateNode(@Nonnull
                       String nodeId,
                       @Nonnull
                       Node.NodeState state,
                       @Nonnull
                       String ip,
                       @Nonnull
                       Long cacheListenerPort,
                       @Nonnull
                       Long nodeBuildNumber,
                       String nodeVersion)

Stores the node in the underlying database.

Parameters:

nodeId - - the node id to store in the underlying table

state - - the desired node state

cacheListenerPort - the multicast port the server is going to use to listen for changes

nodeBuildNumber - build number of the code the node is running

nodeVersion -

Returns:

the newly created node

Throws:

DataAccessException - if a database error prevents the node from being updated

deleteNode

public int deleteNode(Node node)

Deletes the node from the underlying database.

Parameters:

node - the node to delete

Returns:

the number of rows deleted

getNode

@Nullable
public Node getNode(String nodeId)

getAllNodes

public List<Node> getAllNodes()

findNodes

public List<Node> findNodes(org.ofbiz.core.entity.EntityCondition condition,
                            List<String> orderBy)