public class KeyedBatchSubscriber<K,T> extends BaseSubscription<T>
Constructor and Description |
---|
KeyedBatchSubscriber(Fiber context,
Callback<Map<K,T>> target,
Filter<T> filter,
int flushIntervalInMs,
TimeUnit timeUnit,
Converter<T,K> keyResolver) |
KeyedBatchSubscriber(Fiber context,
Callback<Map<K,T>> target,
int flushIntervalInMs,
TimeUnit timeUnit,
Converter<T,K> keyResolver) |
Modifier and Type | Method and Description |
---|---|
protected void |
onMessageOnProducerThread(T msg)
Message received and batched on producer thread.
|
getQueue, onMessage
public KeyedBatchSubscriber(Fiber context, Callback<Map<K,T>> target, Filter<T> filter, int flushIntervalInMs, TimeUnit timeUnit, Converter<T,K> keyResolver)
protected void onMessageOnProducerThread(T msg)
onMessageOnProducerThread
in class BaseSubscription<T>
Copyright © 2017. All Rights Reserved.