public class BatchSubscriber<T> extends BaseSubscription<T>
Constructor and Description |
---|
BatchSubscriber(Fiber queue,
Callback<List<T>> receive,
Filter<T> filter,
int interval,
TimeUnit timeUnit) |
BatchSubscriber(Fiber queue,
Callback<List<T>> receive,
int interval,
TimeUnit timeUnit) |
Modifier and Type | Method and Description |
---|---|
protected void |
onMessageOnProducerThread(T msg)
Receives message and batches as needed.
|
getQueue, onMessage
public BatchSubscriber(Fiber queue, Callback<List<T>> receive, Filter<T> filter, int interval, TimeUnit timeUnit)
protected void onMessageOnProducerThread(T msg)
onMessageOnProducerThread
in class BaseSubscription<T>
Copyright © 2017. All Rights Reserved.