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

ClusterNodeHandler(Mapper clusterNodeMapper, RepositoryDescriptor repositoryDescriptor)

Method Summary

void	addQueue(InvalidationsQueue queue) Adds an invalidation queue to this cluster node.
void	close()
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

close

public void close()
           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