Class | Description |
---|---|
AbstractMessageConsumerManager | |
AbstractMessageDispatcherFactory<W> |
This class does all the hard work of building and maintaining the state of the message
dispatchers so that concrete implementations only need to focus on dispatching the messages.
|
AsyncDispatcherImpl<W,S extends Message,T extends Message> | |
DispatcherState<W,S extends Message,T extends Message> |
The state and metrics pertaining to a particular dispatches.
|
SinkStrategy |
Enum | Description |
---|---|
SinkStrategy.Strategy |
Copyright © 2017. All rights reserved.