BaseSubscription(DisposingExecutor fiber,
Filter<T> _filter) |
BatchSubscriber(Fiber queue,
Callback<List<T>> receive,
Filter<T> filter,
int interval,
TimeUnit timeUnit) |
ChannelSubscription(DisposingExecutor fiber,
Callback<T> receiveMethod,
Filter<T> filter) |
KeyedBatchSubscriber(Fiber context,
Callback<Map<K,T>> target,
Filter<T> filter,
int flushIntervalInMs,
TimeUnit timeUnit,
Converter<T,K> keyResolver) |
LastSubscriber(Fiber context,
Callback<T> target,
Filter<T> filter,
int flushInterval,
TimeUnit timeUnit) |
RecyclingBatchSubscriber(Fiber queue,
Callback<MessageReader<T>> receive,
Filter<T> filter,
int interval,
TimeUnit timeUnit) |