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–2019 The Apache Software Foundation. All rights reserved.