| Modifier and Type | Class and Description |
|---|---|
class |
ExampleClient
An example leader selector client.
|
| Modifier and Type | Method and Description |
|---|---|
Listenable<ConnectionStateListener> |
CuratorFramework.getConnectionStateListenable()
Returns the listenable interface for the Connect State
|
| Modifier and Type | Method and Description |
|---|---|
Listenable<ConnectionStateListener> |
CuratorFrameworkImpl.getConnectionStateListenable() |
| Modifier and Type | Interface and Description |
|---|---|
interface |
LeaderSelectorListener
Notification for leadership
|
| Modifier and Type | Class and Description |
|---|---|
class |
LeaderSelectorListenerAdapter
An implementation of
LeaderSelectorListener that adds the recommended handling
for connection state problems |
| Modifier and Type | Interface and Description |
|---|---|
interface |
QueueConsumer<T>
Message Consumer
|
| Modifier and Type | Class and Description |
|---|---|
class |
BlockingQueueConsumer<T>
Utility - a queue consumer that provides behavior similar to a
BlockingQueue |
| Constructor and Description |
|---|
BlockingQueueConsumer(ConnectionStateListener connectionStateListener)
Creates with capacity of
Integer.MAX_VALUE |
BlockingQueueConsumer(ConnectionStateListener connectionStateListener,
BlockingQueue<T> queue)
Wrap the given blocking queue
|
BlockingQueueConsumer(ConnectionStateListener connectionStateListener,
int capacity) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
SharedCountListener
Listener for changes to a shared count
|
interface |
SharedValueListener
Listener for changes to a shared value
|
| Modifier and Type | Method and Description |
|---|---|
ListenerContainer<ConnectionStateListener> |
ConnectionStateManager.getListenable()
Return the listenable
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
ServiceCacheListener
Listener for changes to a service cache
|
Copyright © 2011–2021 The Apache Software Foundation. All rights reserved.