Modifier and Type | Method and Description |
---|---|
AsyncPolicy |
SinkModule.getAsyncPolicy()
Defines how messages should be asynchronously dispatched.
|
Modifier and Type | Method and Description |
---|---|
<T> DispatchQueue<T> |
DispatchQueueFactory.getQueue(AsyncPolicy asyncPolicy,
String moduleName,
java.util.function.Function<T,byte[]> serializer,
java.util.function.Function<byte[],T> deserializer) |
Constructor and Description |
---|
AsyncDispatcherImpl(DispatcherState<W,S,T> state,
AsyncPolicy asyncPolicy,
SyncDispatcher<S> syncDispatcher) |
Modifier and Type | Method and Description |
---|---|
AsyncPolicy |
MockSinkModule.getAsyncPolicy() |
Modifier and Type | Method and Description |
---|---|
<T> DispatchQueue<T> |
QueueFileOffHeapDispatchQueueFactory.getQueue(AsyncPolicy asyncPolicy,
String moduleName,
java.util.function.Function<T,byte[]> serializer,
java.util.function.Function<byte[],T> deserializer) |
Modifier and Type | Method and Description |
---|---|
AsyncPolicy |
EventSinkModule.getAsyncPolicy() |
Modifier and Type | Method and Description |
---|---|
AsyncPolicy |
HeartbeatModule.getAsyncPolicy() |
Modifier and Type | Method and Description |
---|---|
AsyncPolicy |
SyslogSinkModule.getAsyncPolicy() |
Modifier and Type | Method and Description |
---|---|
AsyncPolicy |
TelemetrySinkModule.getAsyncPolicy() |
Modifier and Type | Method and Description |
---|---|
AsyncPolicy |
TrapSinkModule.getAsyncPolicy() |
Copyright © 2020. All rights reserved.