public class RecyclingBatchSubscriber<T> extends BaseSubscription<T>
Constructor and Description |
---|
RecyclingBatchSubscriber(Fiber queue,
Callback<MessageReader<T>> receive,
Filter<T> filter,
int interval,
TimeUnit timeUnit) |
RecyclingBatchSubscriber(Fiber queue,
Callback<MessageReader<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 RecyclingBatchSubscriber(Fiber queue, Callback<MessageReader<T>> receive, Filter<T> filter, int interval, TimeUnit timeUnit)
public RecyclingBatchSubscriber(Fiber queue, Callback<MessageReader<T>> receive, int interval, TimeUnit timeUnit)
protected void onMessageOnProducerThread(T msg)
onMessageOnProducerThread
in class BaseSubscription<T>
Copyright © 2017. All Rights Reserved.