@FunctionalInterface public interface ConnectionStateListenerManagerFactory
Modifier and Type | Field and Description |
---|---|
static ConnectionStateListenerManagerFactory |
standard
Pass through
|
Modifier and Type | Method and Description |
---|---|
static ConnectionStateListenerManagerFactory |
circuitBreaking(RetryPolicy retryPolicy)
Listeners set in this manager receive circuit breaking behavior using
CircuitBreakingConnectionStateListener
as a master listener that proxies to any listener registered by client code (unless the listener returns true
for ConnectionStateListener.doNotProxy() ). |
static ConnectionStateListenerManagerFactory |
circuitBreaking(RetryPolicy retryPolicy,
ScheduledExecutorService service)
Listeners set in this manager receive circuit breaking behavior using
CircuitBreakingConnectionStateListener
as a master listener that proxies to any listener registered by client code (unless the listener returns true
for ConnectionStateListener.doNotProxy() ). |
UnaryListenerManager<ConnectionStateListener> |
newManager(CuratorFramework client)
Create a new listener manager
|
static final ConnectionStateListenerManagerFactory standard
UnaryListenerManager<ConnectionStateListener> newManager(CuratorFramework client)
client
- curator clientstatic ConnectionStateListenerManagerFactory circuitBreaking(RetryPolicy retryPolicy)
CircuitBreakingConnectionStateListener
as a master listener that proxies to any listener registered by client code (unless the listener returns true
for ConnectionStateListener.doNotProxy()
).retryPolicy
- the circuit breaking policy to usestatic ConnectionStateListenerManagerFactory circuitBreaking(RetryPolicy retryPolicy, ScheduledExecutorService service)
CircuitBreakingConnectionStateListener
as a master listener that proxies to any listener registered by client code (unless the listener returns true
for ConnectionStateListener.doNotProxy()
).retryPolicy
- the circuit breaking policy to useservice
- the scheduler to useCopyright © 2011–2023 The Apache Software Foundation. All rights reserved.