org.nuxeo.ecm.core.storage.sql.jdbc

Class ClusterNodeHandler

java.lang.Object

org.nuxeo.ecm.core.storage.sql.jdbc.ClusterNodeHandler

public class ClusterNodeHandler
extends Object

Encapsulates cluster node operations.

There is one cluster node handler per cluster node (repository).

Constructor Summary

Constructors

Constructor and Description
ClusterNodeHandler(Mapper clusterNodeMapper, RepositoryDescriptor repositoryDescriptor)

Method Summary

Methods

Modifier and Type	Method and Description
void	addQueue(InvalidationsQueue queue) Adds an invalidation queue to this cluster node.
void	close()
void	connectionWasReset()
JDBCConnection	getConnection()
void	processClusterInvalidationsNext()
void	propagateInvalidations(Invalidations invalidations, InvalidationsQueue skipQueue) Propagates invalidations to all the queues of this cluster node.
Invalidations	receiveClusterInvalidations() Receives cluster invalidations from other cluster nodes.
void	removeQueue(InvalidationsQueue queue) Removes an invalidation queue from this cluster node.
void	sendClusterInvalidations(Invalidations invalidations) Sends cluster invalidations to other cluster nodes.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterNodeHandler

public ClusterNodeHandler(Mapper clusterNodeMapper,
                  RepositoryDescriptor repositoryDescriptor)
                   throws StorageException

Throws:

StorageException

Method Detail

getConnection

public JDBCConnection getConnection()

close

public void close()
           throws StorageException

Throws:

StorageException

connectionWasReset

public void connectionWasReset()
                        throws StorageException

Throws:

StorageException

processClusterInvalidationsNext

public void processClusterInvalidationsNext()

addQueue

public void addQueue(InvalidationsQueue queue)

Adds an invalidation queue to this cluster node.

removeQueue

public void removeQueue(InvalidationsQueue queue)

Removes an invalidation queue from this cluster node.

propagateInvalidations

public void propagateInvalidations(Invalidations invalidations,
                          InvalidationsQueue skipQueue)

Propagates invalidations to all the queues of this cluster node.

receiveClusterInvalidations

public Invalidations receiveClusterInvalidations()
                                          throws StorageException

Receives cluster invalidations from other cluster nodes.

Throws:

StorageException

sendClusterInvalidations

public void sendClusterInvalidations(Invalidations invalidations)
                              throws StorageException

Sends cluster invalidations to other cluster nodes.

Throws:

StorageException