Interface | Description |
---|---|
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.
|
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 |
Generates a dispatcher for the given
SinkModule . |
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.
|
Copyright © 2018. All rights reserved.