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

java.lang.Object
  org.nuxeo.ecm.core.storage.sql.jdbc.ClusterNodeHandler

public class ClusterNodeHandler
extends java.lang.Object

Encapsulates cluster node operations.

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

Field Summary

InvalidationsPropagator

propagator Propagator of invalidations to the cluster node's mappers.

Constructor Summary

ClusterNodeHandler(Mapper clusterNodeMapper, RepositoryDescriptor repositoryDescriptor)

Method Summary

void	close()
void	processClusterInvalidationsNext()
Invalidations	receiveClusterInvalidations() Receives cluster invalidations from other cluster nodes.
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

Field Detail

propagator

public final InvalidationsPropagator propagator

Propagator of invalidations to the cluster node's mappers.

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

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