public interface IConnectionCallback
A class that is called when a TaskMessage arrives.
| Modifier and Type | Method and Description |
|---|---|
void |
recv(List<TaskMessage> batch)
A batch of new messages have arrived to be processed.
|
void recv(List<TaskMessage> batch)
A batch of new messages have arrived to be processed.
batch - the messages to be processedCopyright © 2021 The Apache Software Foundation. All rights reserved.