public class ConsumerBatchMessage<T> extends Object
| Constructor and Description |
|---|
ConsumerBatchMessage(List<T> data) |
| Modifier and Type | Method and Description |
|---|---|
void |
ack()
Countdown if the sub message is successful.
|
void |
fail()
Countdown and fail-fast if the sub message is failed.
|
List<T> |
getData() |
boolean |
isSuccess() |
boolean |
waitFinish(long timeout) |
public boolean waitFinish(long timeout)
throws InterruptedException
InterruptedExceptionpublic boolean isSuccess()
public void ack()
Countdown if the sub message is successful.
public void fail()
Countdown and fail-fast if the sub message is failed.
Copyright © 2021 The Apache Software Foundation. All rights reserved.