类的使用
org.joyqueue.client.internal.consumer.domain.ConsumeReply

使用ConsumeReply的程序包

程序包	说明
io.openmessaging.joyqueue.consumer.support
org.joyqueue.client.internal.consumer
org.joyqueue.client.internal.consumer.converter
org.joyqueue.client.internal.consumer.interceptor
org.joyqueue.client.internal.consumer.support
org.joyqueue.client.internal.trace.interceptor

io.openmessaging.joyqueue.consumer.support中ConsumeReply的使用

类型变量类型为ConsumeReply的io.openmessaging.joyqueue.consumer.support中的方法参数

限定符和类型	方法和说明
void	ConsumerInterceptorAdapter.postConsume(ConsumeContext context, List<ConsumeReply> consumeReplies)

org.joyqueue.client.internal.consumer中ConsumeReply的使用

参数类型为ConsumeReply的org.joyqueue.client.internal.consumer中的方法

限定符和类型	方法和说明
org.joyqueue.exception.JoyQueueCode	MessageConsumer.replyOnce(ConsumeReply reply)
org.joyqueue.exception.JoyQueueCode	MessagePoller.replyOnce(String topic, ConsumeReply reply)

类型变量类型为ConsumeReply的org.joyqueue.client.internal.consumer中的方法参数

限定符和类型	方法和说明
Map<String,org.joyqueue.exception.JoyQueueCode>	ConsumerIndexManager.batchCommitReply(Map<String,List<ConsumeReply>> replyMap, String app, long timeout)
org.joyqueue.exception.JoyQueueCode	ConsumerIndexManager.commitReply(String topic, List<ConsumeReply> replyList, String app, long timeout)
org.joyqueue.exception.JoyQueueCode	MessageConsumer.reply(List<ConsumeReply> replyList)
org.joyqueue.exception.JoyQueueCode	MessagePoller.reply(String topic, List<ConsumeReply> replyList)

org.joyqueue.client.internal.consumer.converter中ConsumeReply的使用

返回变量类型为ConsumeReply的类型的org.joyqueue.client.internal.consumer.converter中的方法

限定符和类型	方法和说明
static List<ConsumeReply>	ConsumeMessageConverter.convertToReply(List<ConsumeMessage> messages, RetryType retryType)

org.joyqueue.client.internal.consumer.interceptor中ConsumeReply的使用

返回变量类型为ConsumeReply的类型的org.joyqueue.client.internal.consumer.interceptor中的方法

限定符和类型	方法和说明
List<ConsumeReply>	ConsumerInvocation.invoke()
List<ConsumeReply>	ConsumerInvoker.invoke(ConsumeContext context)
List<ConsumeReply>	ConsumerInvoker.reject(ConsumeContext context)

类型变量类型为ConsumeReply的org.joyqueue.client.internal.consumer.interceptor中的方法参数

限定符和类型	方法和说明
void	ConsumerInterceptor.postConsume(ConsumeContext context, List<ConsumeReply> consumeReplies)

org.joyqueue.client.internal.consumer.support中ConsumeReply的使用

返回变量类型为ConsumeReply的类型的org.joyqueue.client.internal.consumer.support中的方法

限定符和类型	方法和说明
protected List<ConsumeReply>	TopicMessageConsumerDispatcher.doBatchDispatch(TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages, List<BatchMessageListener> listeners)
protected List<ConsumeReply>	TopicMessageConsumerDispatcher.doDispatch(TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages)
protected List<ConsumeReply>	TopicMessageConsumerDispatcher.doOnceDispatch(TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages, List<MessageListener> listeners)
List<ConsumeReply>	BatchConsumerInvoker.invoke(ConsumeContext context)
List<ConsumeReply>	OnceConsumerInvoker.invoke(ConsumeContext context)
List<ConsumeReply>	BatchConsumerInvoker.reject(ConsumeContext context)
List<ConsumeReply>	OnceConsumerInvoker.reject(ConsumeContext context)

参数类型为ConsumeReply的org.joyqueue.client.internal.consumer.support中的方法

限定符和类型	方法和说明
org.joyqueue.exception.JoyQueueCode	MessageConsumerWrapper.replyOnce(ConsumeReply reply)
org.joyqueue.exception.JoyQueueCode	DefaultMessageConsumer.replyOnce(ConsumeReply reply)
org.joyqueue.exception.JoyQueueCode	BroadcastMessagePoller.replyOnce(String topic, ConsumeReply reply)
org.joyqueue.exception.JoyQueueCode	DefaultMessagePoller.replyOnce(String topic, ConsumeReply reply)
org.joyqueue.exception.JoyQueueCode	MessagePollerWrapper.replyOnce(String topic, ConsumeReply reply)
org.joyqueue.exception.JoyQueueCode	PartitionMessagePoller.replyOnce(String topic, ConsumeReply reply)

类型变量类型为ConsumeReply的org.joyqueue.client.internal.consumer.support中的方法参数

限定符和类型	方法和说明
Map<String,org.joyqueue.exception.JoyQueueCode>	LocalConsumerIndexManager.batchCommitReply(Map<String,List<ConsumeReply>> replyMap, String app, long timeout)
Map<String,org.joyqueue.exception.JoyQueueCode>	DefaultConsumerIndexManager.batchCommitReply(Map<String,List<ConsumeReply>> replyMap, String app, long timeout)
protected Map<BrokerNode,com.google.common.collect.Table<String,Short,List<CommitAckData>>>	DefaultConsumerIndexManager.buildCommitAckParams(Map<String,List<ConsumeReply>> ackMap, String app)
org.joyqueue.exception.JoyQueueCode	LocalConsumerIndexManager.commitReply(String topic, List<ConsumeReply> replyList, String app, long timeout)
org.joyqueue.exception.JoyQueueCode	DefaultConsumerIndexManager.commitReply(String topic, List<ConsumeReply> replyList, String app, long timeout)
org.joyqueue.exception.JoyQueueCode	MessageConsumerWrapper.reply(List<ConsumeReply> replyList)
org.joyqueue.exception.JoyQueueCode	DefaultMessageConsumer.reply(List<ConsumeReply> replyList)
org.joyqueue.exception.JoyQueueCode	BroadcastMessagePoller.reply(String topic, List<ConsumeReply> replyList)
org.joyqueue.exception.JoyQueueCode	DefaultMessagePoller.reply(String topic, List<ConsumeReply> replyList)
org.joyqueue.exception.JoyQueueCode	MessagePollerWrapper.reply(String topic, List<ConsumeReply> replyList)
org.joyqueue.exception.JoyQueueCode	PartitionMessagePoller.reply(String topic, List<ConsumeReply> replyList)

org.joyqueue.client.internal.trace.interceptor中ConsumeReply的使用

类型变量类型为ConsumeReply的org.joyqueue.client.internal.trace.interceptor中的方法参数

限定符和类型	方法和说明
void	TraceConsumerInterceptor.postConsume(ConsumeContext context, List<ConsumeReply> consumeReplies)