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

使用FetchMessageData的程序包

程序包	说明
org.joyqueue.client.internal.consumer
org.joyqueue.client.internal.consumer.callback
org.joyqueue.client.internal.consumer.converter
org.joyqueue.client.internal.consumer.support

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

返回FetchMessageData的org.joyqueue.client.internal.consumer中的方法

限定符和类型	方法和说明
FetchMessageData	MessageFetcher.fetch(BrokerNode brokerNode, String topic, String app, int count, long timeout, long ackTimeout, long longPollTimeout)
FetchMessageData	MessageFetcher.fetchPartition(BrokerNode brokerNode, String topic, String app, short partition, int count, long timeout)
FetchMessageData	MessageFetcher.fetchPartition(BrokerNode brokerNode, String topic, String app, short partition, long index, int count, long timeout)

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

限定符和类型	方法和说明
Map<String,FetchMessageData>	MessageFetcher.batchFetch(BrokerNode brokerNode, List<String> topics, String app, int count, long timeout, long ackTimeout, long longPollTimeout)
com.google.common.collect.Table<String,Short,FetchMessageData>	MessageFetcher.batchFetchPartitions(BrokerNode brokerNode, Map<String,Short> partitions, String app, int count, long timeout)
com.google.common.collect.Table<String,Short,FetchMessageData>	MessageFetcher.batchFetchPartitions(BrokerNode brokerNode, com.google.common.collect.Table<String,Short,Long> partitions, String app, int count, long timeout)

org.joyqueue.client.internal.consumer.callback中FetchMessageData的使用

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

限定符和类型	方法和说明
void	PartitionConsumerListener.onMessage(FetchMessageData fetchMessageData)
void	FetchListener.onMessage(FetchMessageData fetchMessageData)
void	PartitionFetchListener.onMessage(FetchMessageData fetchMessageData)

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

限定符和类型	方法和说明
void	BatchFetchListener.onMessage(Map<String,FetchMessageData> fetchMessageMap)
void	BatchPartitionFetchListener.onMessage(com.google.common.collect.Table<String,Short,FetchMessageData> fetchMessageTable)

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

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

限定符和类型	方法和说明
static Map<String,FetchMessageData>	BrokerMessageConverter.convert(String app, Map<String,FetchTopicMessageAckData> topicMessageMap)
static com.google.common.collect.Table<String,Short,FetchMessageData>	BrokerMessageConverter.convert(String app, com.google.common.collect.Table<String,Short,FetchPartitionMessageAckData> topicMessageTable)

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

返回FetchMessageData的org.joyqueue.client.internal.consumer.support中的方法

限定符和类型	方法和说明
FetchMessageData	MessageFetcherWrapper.fetch(BrokerNode brokerNode, String topic, String app, int count, long timeout, long ackTimeout, long longPollTimeout)
FetchMessageData	DefaultMessageFetcher.fetch(BrokerNode brokerNode, String topic, String app, int count, long timeout, long ackTimeout, long longPollTimeout)
FetchMessageData	MessageFetcherWrapper.fetchPartition(BrokerNode brokerNode, String topic, String app, short partition, int count, long timeout)
FetchMessageData	DefaultMessageFetcher.fetchPartition(BrokerNode brokerNode, String topic, String app, short partition, int count, long timeout)
FetchMessageData	MessageFetcherWrapper.fetchPartition(BrokerNode brokerNode, String topic, String app, short partition, long index, int count, long timeout)
FetchMessageData	DefaultMessageFetcher.fetchPartition(BrokerNode brokerNode, String topic, String app, short partition, long index, int count, long timeout)

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

限定符和类型	方法和说明
Map<String,FetchMessageData>	MessageFetcherWrapper.batchFetch(BrokerNode brokerNode, List<String> topics, String app, int count, long timeout, long ackTimeout, long longPollTimeout)
Map<String,FetchMessageData>	DefaultMessageFetcher.batchFetch(BrokerNode brokerNode, List<String> topics, String app, int count, long timeout, long ackTimeout, long longPollTimeout)
com.google.common.collect.Table<String,Short,FetchMessageData>	MessageFetcherWrapper.batchFetchPartitions(BrokerNode brokerNode, Map<String,Short> partitions, String app, int count, long timeout)
com.google.common.collect.Table<String,Short,FetchMessageData>	DefaultMessageFetcher.batchFetchPartitions(BrokerNode brokerNode, Map<String,Short> partitions, String app, int count, long timeout)
com.google.common.collect.Table<String,Short,FetchMessageData>	MessageFetcherWrapper.batchFetchPartitions(BrokerNode brokerNode, com.google.common.collect.Table<String,Short,Long> partitions, String app, int count, long timeout)
com.google.common.collect.Table<String,Short,FetchMessageData>	DefaultMessageFetcher.batchFetchPartitions(BrokerNode brokerNode, com.google.common.collect.Table<String,Short,Long> partitions, String app, int count, long timeout)

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

限定符和类型	方法和说明
protected List<ConsumeMessage>	MessagePollerInner.handleFetchMessageData(String topic, String app, FetchMessageData fetchMessageData)