Uses of Interface
org.apache.curator.framework.state.ConnectionStateListener
Package
Description
-
Uses of ConnectionStateListener in leader
-
Uses of ConnectionStateListener in org.apache.curator.framework
Modifier and TypeMethodDescriptionCuratorFramework.getConnectionStateListenable()
Returns the listenable interface for the Connect State -
Uses of ConnectionStateListener in org.apache.curator.framework.imps
-
Uses of ConnectionStateListener in org.apache.curator.framework.recipes.leader
Modifier and TypeInterfaceDescriptioninterface
Notification for leadershipModifier and TypeClassDescriptionclass
An implementation ofLeaderSelectorListener
that adds the recommended handling for connection state problems -
Uses of ConnectionStateListener in org.apache.curator.framework.recipes.queue
Modifier and TypeClassDescriptionclass
Utility - a queue consumer that provides behavior similar to aBlockingQueue
ModifierConstructorDescriptionBlockingQueueConsumer
(ConnectionStateListener connectionStateListener) Creates with capacity ofInteger.MAX_VALUE
BlockingQueueConsumer
(ConnectionStateListener connectionStateListener, int capacity) BlockingQueueConsumer
(ConnectionStateListener connectionStateListener, BlockingQueue<T> queue) Wrap the given blocking queue -
Uses of ConnectionStateListener in org.apache.curator.framework.state
Modifier and TypeClassDescriptionclass
A proxy for connection state listeners that adds circuit breaking behavior.Modifier and TypeMethodDescriptionConnectionStateManager.getListenable()
Return the listenableConnectionStateListenerManagerFactory.newManager
(CuratorFramework client) Create a new listener managerModifierConstructorDescriptionCircuitBreakingConnectionStateListener
(CuratorFramework client, ConnectionStateListener listener, RetryPolicy retryPolicy) CircuitBreakingConnectionStateListener
(CuratorFramework client, ConnectionStateListener listener, RetryPolicy retryPolicy, ScheduledExecutorService service) -
Uses of ConnectionStateListener in org.apache.curator.x.discovery.details
Modifier and TypeInterfaceDescriptioninterface
Listener for changes to a service cache