Package org.apache.activemq.artemis.quorum.zookeeper

Class CuratorDistributedPrimitive

java.lang.Object

org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitive

All Implemented Interfaces:

java.lang.AutoCloseable

public abstract class CuratorDistributedPrimitive
extends java.lang.Object
implements java.lang.AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static interface	CuratorDistributedPrimitive.InterruptablePrimitiveAction<R,T extends java.lang.Throwable>
protected static interface	CuratorDistributedPrimitive.PrimitiveAction<R,T extends java.lang.Throwable>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CuratorDistributedPrimitive(org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager.PrimitiveId id, CuratorDistributedPrimitiveManager manager)

Method Summary

Modifier and Type	Method	Description
protected void	checkUnavailable()
void	close()
protected void	fireUnavailableListener(java.lang.Runnable task)
protected void	handleClosed()
protected void	handleLost()
protected void	handleReconnected()
protected void	handleSuspended()
protected boolean	isUnavailable()
protected <R,T extends java.lang.Throwable> R	run(CuratorDistributedPrimitive.PrimitiveAction<R,T> action)
protected <R,T extends java.lang.Throwable> R	tryRun(CuratorDistributedPrimitive.InterruptablePrimitiveAction<R,T> action)

Methods inherited from class java.lang.Object

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

Constructor Detail

CuratorDistributedPrimitive

protected CuratorDistributedPrimitive(org.apache.activemq.artemis.quorum.zookeeper.CuratorDistributedPrimitiveManager.PrimitiveId id,
                                      CuratorDistributedPrimitiveManager manager)

Method Detail

handleReconnected

protected void handleReconnected()

handleLost

protected void handleLost()

handleSuspended

protected void handleSuspended()

checkUnavailable

protected final void checkUnavailable()
                               throws org.apache.activemq.artemis.quorum.UnavailableStateException

Throws:

org.apache.activemq.artemis.quorum.UnavailableStateException

fireUnavailableListener

protected final void fireUnavailableListener(java.lang.Runnable task)

run

protected final <R,T extends java.lang.Throwable> R run(CuratorDistributedPrimitive.PrimitiveAction<R,T> action)
                                                       throws T extends java.lang.Throwable

Throws:

T extends java.lang.Throwable

tryRun

protected final <R,T extends java.lang.Throwable> R tryRun(CuratorDistributedPrimitive.InterruptablePrimitiveAction<R,T> action)
                                                          throws java.lang.InterruptedException,
                                                                 T extends java.lang.Throwable

Throws:

java.lang.InterruptedException

T extends java.lang.Throwable

handleClosed

protected void handleClosed()

isUnavailable

protected final boolean isUnavailable()

close

public final void close()

Specified by:

close in interface java.lang.AutoCloseable