Package org.openspaces.admin.internal.pu.quiesce

Class ZookeeperQuiesceManager

java.lang.Object

org.openspaces.admin.internal.pu.quiesce.ZookeeperQuiesceManager

All Implemented Interfaces:

QuiesceManager

public class ZookeeperQuiesceManager
extends Object
implements QuiesceManager

Field Summary

Fields inherited from interface org.openspaces.admin.internal.pu.quiesce.QuiesceManager

DEFAULT_EMPTY_DETAILS

Constructor Summary

Constructors

Constructor	Description
ZookeeperQuiesceManager(org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore attributeStore)

Method Summary

Modifier and Type	Method	Description
InternalQuiesceDetails	getInternalQuiesceDetails(ProcessingUnit processingUnit)
QuiesceDetails	getQuiesceDetails(ProcessingUnit processingUnit)
InternalQuiesceDetails	quiesce(ProcessingUnit processingUnit, QuiesceRequest request)
void	unquiesce(ProcessingUnit processingUnit, QuiesceRequest request)

Methods inherited from class java.lang.Object

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

Constructor Details

ZookeeperQuiesceManager

public ZookeeperQuiesceManager(org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore attributeStore)

Method Details

quiesce

public InternalQuiesceDetails quiesce(ProcessingUnit processingUnit,
 QuiesceRequest request)
                               throws IOException,
QuiesceFailedException

Specified by:

quiesce in interface QuiesceManager

Throws:

IOException

QuiesceFailedException

unquiesce

public void unquiesce(ProcessingUnit processingUnit,
 QuiesceRequest request)
               throws IOException

Specified by:

unquiesce in interface QuiesceManager

Throws:

IOException

getQuiesceDetails

public QuiesceDetails getQuiesceDetails(ProcessingUnit processingUnit)
                                 throws IOException

Specified by:

getQuiesceDetails in interface QuiesceManager

Throws:

IOException

getInternalQuiesceDetails

public InternalQuiesceDetails getInternalQuiesceDetails(ProcessingUnit processingUnit)
                                                 throws IOException

Specified by:

getInternalQuiesceDetails in interface QuiesceManager

Throws:

IOException