public class CompletableFutureAsyncProduceCallback extends Object implements AsyncProduceCallback
| 构造器和说明 |
|---|
CompletableFutureAsyncProduceCallback(CompletableFuture<SendResult> future) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
onException(ProduceMessage message,
Throwable cause) |
void |
onSuccess(ProduceMessage message,
SendResult result) |
public CompletableFutureAsyncProduceCallback(CompletableFuture<SendResult> future)
public void onSuccess(ProduceMessage message, SendResult result)
onSuccess 在接口中 AsyncProduceCallbackpublic void onException(ProduceMessage message, Throwable cause)
onException 在接口中 AsyncProduceCallbackCopyright © 2020 Joyqueue Community. All rights reserved.