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

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

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)

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

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)