AggregationPolicy<S,T,U> |
Defines how messages will be aggregated.
|
AsyncDispatcher<S extends Message> |
Used to asynchronously dispatch messages.
|
AsyncPolicy |
Defines the behavior of asynchronous dispatching.
|
DispatchQueue<T> |
|
DispatchQueueFactory |
|
Message |
Marker interface for messages that are produced and consumed by a SinkModule .
|
MessageConsumer<S extends Message,T extends Message> |
Implemented by consumers of a particular SinkModule .
|
MessageConsumerManager |
Handles dispatching of messages to the registered consumer(s).
|
MessageDispatcher<S> |
Used to synchronously dispatch messages.
|
MessageDispatcherFactory |
|
SinkModule<S extends Message,T extends Message> |
Defines how the messages will be routed and marshaled/unmarshaled over the wire.
|
SyncDispatcher<S extends Message> |
Used to synchronously dispatch messages.
|