org.joyqueue.client.internal.consumer.callback

接口 PollerListener

所有已知实现类:

CompletableFuturePollerListener

public interface PollerListener

BatchFetchListener author: gaohaoxiang date: 2018/12/10

方法概要

限定符和类型	方法和说明
void	onException(Throwable cause)
void	onMessage(List<ConsumeMessage> messages)

方法详细资料

onMessage

void onMessage(List<ConsumeMessage> messages)

onException

void onException(Throwable cause)