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

使用ConsumeMessage的程序包

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

io.openmessaging.joyqueue.consumer.message中ConsumeMessage的使用

返回ConsumeMessage的io.openmessaging.joyqueue.consumer.message中的方法

限定符和类型	方法和说明
ConsumeMessage	MessageReceiptAdapter.getMessage()

参数类型为ConsumeMessage的io.openmessaging.joyqueue.consumer.message中的方法

限定符和类型	方法和说明
static io.openmessaging.message.Message	MessageConverter.convertMessage(ConsumeMessage consumeMessage)

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

限定符和类型	方法和说明
static List<io.openmessaging.message.Message>	MessageConverter.convertMessages(List<ConsumeMessage> consumeMessages)

参数类型为ConsumeMessage的io.openmessaging.joyqueue.consumer.message中的构造器

构造器和说明
MessageAdapter(ConsumeMessage message)
MessageExtensionHeaderAdapter(ConsumeMessage message)
MessageHeaderAdapter(ConsumeMessage message)
MessagePropertiesAdapter(ConsumeMessage message)
MessageReceiptAdapter(ConsumeMessage message)

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

参数类型为ConsumeMessage的io.openmessaging.joyqueue.consumer.support中的方法

限定符和类型	方法和说明
void	MessageListenerAdapter.onMessage(ConsumeMessage message)

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

限定符和类型	方法和说明
void	BatchMessageListenerAdapter.onMessage(List<ConsumeMessage> messages)

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

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

限定符和类型	方法和说明
ConsumeMessage	MessageConsumer.pollOnce()
ConsumeMessage	MessageConsumer.pollOnce(long timeout, TimeUnit timeoutUnit)
ConsumeMessage	MessagePoller.pollOnce(String topic)
ConsumeMessage	MessagePoller.pollOnce(String topic, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	MessageConsumer.pollPartitionOnce(short partition)
ConsumeMessage	MessageConsumer.pollPartitionOnce(short partition, long index)
ConsumeMessage	MessageConsumer.pollPartitionOnce(short partition, long index, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	MessageConsumer.pollPartitionOnce(short partition, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	MessagePoller.pollPartitionOnce(String topic, short partition)
ConsumeMessage	MessagePoller.pollPartitionOnce(String topic, short partition, long index)
ConsumeMessage	MessagePoller.pollPartitionOnce(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	MessagePoller.pollPartitionOnce(String topic, short partition, long timeout, TimeUnit timeoutUnit)

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

限定符和类型	方法和说明
List<ConsumeMessage>	MessageConsumer.poll()
List<ConsumeMessage>	MessageConsumer.poll(long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	MessagePoller.poll(String topic)
List<ConsumeMessage>	MessagePoller.poll(String topic, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessageConsumer.pollAsync()
CompletableFuture<List<ConsumeMessage>>	MessageConsumer.pollAsync(long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessagePoller.pollAsync(String topic)
CompletableFuture<List<ConsumeMessage>>	MessagePoller.pollAsync(String topic, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	MessageConsumer.pollPartition(short partition)
List<ConsumeMessage>	MessageConsumer.pollPartition(short partition, long index)
List<ConsumeMessage>	MessageConsumer.pollPartition(short partition, long index, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	MessageConsumer.pollPartition(short partition, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	MessagePoller.pollPartition(String topic, short partition)
List<ConsumeMessage>	MessagePoller.pollPartition(String topic, short partition, long index)
List<ConsumeMessage>	MessagePoller.pollPartition(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	MessagePoller.pollPartition(String topic, short partition, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessageConsumer.pollPartitionAsync(short partition)
CompletableFuture<List<ConsumeMessage>>	MessageConsumer.pollPartitionAsync(short partition, long index)
CompletableFuture<List<ConsumeMessage>>	MessageConsumer.pollPartitionAsync(short partition, long index, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessageConsumer.pollPartitionAsync(short partition, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessagePoller.pollPartitionAsync(String topic, short partition)
CompletableFuture<List<ConsumeMessage>>	MessagePoller.pollPartitionAsync(String topic, short partition, long index)
CompletableFuture<List<ConsumeMessage>>	MessagePoller.pollPartitionAsync(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessagePoller.pollPartitionAsync(String topic, short partition, long timeout, TimeUnit timeoutUnit)

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

限定符和类型	方法和说明
void	MessageListener.onMessage(ConsumeMessage message)

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

限定符和类型	方法和说明
void	BatchMessageListener.onMessage(List<ConsumeMessage> messages)

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

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

限定符和类型	方法和说明
void	PollerListener.onMessage(List<ConsumeMessage> messages)

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

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

限定符和类型	方法和说明
static ConsumeMessage	BrokerMessageConverter.convert(String topic, String app, org.joyqueue.message.BrokerMessage brokerMessage)

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

限定符和类型	方法和说明
static List<ConsumeMessage>	BrokerMessageConverter.convert(String topic, String app, List<org.joyqueue.message.BrokerMessage> brokerMessages)

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

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

org.joyqueue.client.internal.consumer.domain中ConsumeMessage的使用

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

限定符和类型	方法和说明
List<ConsumeMessage>	FetchMessageData.getMessages()

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

限定符和类型	方法和说明
void	FetchMessageData.setMessages(List<ConsumeMessage> messages)

类型变量类型为ConsumeMessage的org.joyqueue.client.internal.consumer.domain中的构造器参数

构造器和说明
FetchMessageData(List<ConsumeMessage> messages, org.joyqueue.exception.JoyQueueCode code)

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

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

限定符和类型	方法和说明
List<ConsumeMessage>	ConsumeContext.getFilteredMessages()
Set<ConsumeMessage>	ConsumeContext.getMessageFilter()
List<ConsumeMessage>	ConsumeContext.getMessages()

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

限定符和类型	方法和说明
void	ConsumeContext.filterMessage(ConsumeMessage message)
boolean	ConsumeContext.isFilteredMessage(ConsumeMessage message)

类型变量类型为ConsumeMessage的org.joyqueue.client.internal.consumer.interceptor中的构造器参数

构造器和说明
ConsumeContext(String topic, String app, NameServerConfig nameserver, List<ConsumeMessage> messages)
ConsumerInvocation(ConsumerConfig config, String topic, NameServerConfig nameServerConfig, List<ConsumeMessage> messages, ConsumerInterceptorManager consumerInterceptorManager, ConsumerInvoker consumerInvoker)

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

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

限定符和类型	方法和说明
ConsumeMessage	MessageConsumerWrapper.pollOnce()
ConsumeMessage	DefaultMessageConsumer.pollOnce()
ConsumeMessage	MessageConsumerWrapper.pollOnce(long timeout, TimeUnit timeoutUnit)
ConsumeMessage	DefaultMessageConsumer.pollOnce(long timeout, TimeUnit timeoutUnit)
ConsumeMessage	BroadcastMessagePoller.pollOnce(String topic)
ConsumeMessage	DefaultMessagePoller.pollOnce(String topic)
ConsumeMessage	MessagePollerWrapper.pollOnce(String topic)
ConsumeMessage	PartitionMessagePoller.pollOnce(String topic)
ConsumeMessage	BroadcastMessagePoller.pollOnce(String topic, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	DefaultMessagePoller.pollOnce(String topic, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	MessagePollerWrapper.pollOnce(String topic, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	PartitionMessagePoller.pollOnce(String topic, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	MessageConsumerWrapper.pollPartitionOnce(short partition)
ConsumeMessage	DefaultMessageConsumer.pollPartitionOnce(short partition)
ConsumeMessage	MessageConsumerWrapper.pollPartitionOnce(short partition, long index)
ConsumeMessage	DefaultMessageConsumer.pollPartitionOnce(short partition, long index)
ConsumeMessage	MessageConsumerWrapper.pollPartitionOnce(short partition, long index, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	DefaultMessageConsumer.pollPartitionOnce(short partition, long index, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	MessageConsumerWrapper.pollPartitionOnce(short partition, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	DefaultMessageConsumer.pollPartitionOnce(short partition, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	BroadcastMessagePoller.pollPartitionOnce(String topic, short partition)
ConsumeMessage	DefaultMessagePoller.pollPartitionOnce(String topic, short partition)
ConsumeMessage	MessagePollerWrapper.pollPartitionOnce(String topic, short partition)
ConsumeMessage	PartitionMessagePoller.pollPartitionOnce(String topic, short partition)
ConsumeMessage	BroadcastMessagePoller.pollPartitionOnce(String topic, short partition, long index)
ConsumeMessage	DefaultMessagePoller.pollPartitionOnce(String topic, short partition, long index)
ConsumeMessage	MessagePollerWrapper.pollPartitionOnce(String topic, short partition, long index)
ConsumeMessage	PartitionMessagePoller.pollPartitionOnce(String topic, short partition, long index)
ConsumeMessage	BroadcastMessagePoller.pollPartitionOnce(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	DefaultMessagePoller.pollPartitionOnce(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	MessagePollerWrapper.pollPartitionOnce(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	PartitionMessagePoller.pollPartitionOnce(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	BroadcastMessagePoller.pollPartitionOnce(String topic, short partition, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	DefaultMessagePoller.pollPartitionOnce(String topic, short partition, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	MessagePollerWrapper.pollPartitionOnce(String topic, short partition, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	PartitionMessagePoller.pollPartitionOnce(String topic, short partition, long timeout, TimeUnit timeoutUnit)

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

限定符和类型	方法和说明
List<ConsumeMessage>	MessagePollerInner.buildPollEmptyResult(PollerListener listener)
protected List<ConsumeMessage>	MessagePollerInner.doFetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	MessagePollerInner.doFetchTopic(BrokerNode brokerNode, TopicMetadata topicMetadata, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	DefaultMessagePoller.doPoll(String topic, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	PartitionMessagePoller.doPoll(String topic, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	DefaultMessagePoller.doPollPartition(String topic, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	PartitionMessagePoller.doPollPartition(String topic, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	DefaultMessagePoller.doPollPartition(String topic, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	PartitionMessagePoller.doPollPartition(String topic, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	PartitionMessagePoller.doPollPartitionInternal(BrokerNode brokerNode, String topic, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	PartitionMessagePoller.doPollPartitionInternal(BrokerNode brokerNode, String topic, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchPartition(BrokerNode brokerNode, String topic, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchPartition(BrokerNode brokerNode, String topic, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchTopic(BrokerNode brokerNode, String topic, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchTopic(BrokerNode brokerNode, TopicMetadata topicMetadata, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	MessagePollerInner.handleFetchMessageData(String topic, String app, FetchMessageData fetchMessageData)
List<ConsumeMessage>	MessageConsumerWrapper.poll()
List<ConsumeMessage>	DefaultMessageConsumer.poll()
List<ConsumeMessage>	MessageConsumerWrapper.poll(long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	DefaultMessageConsumer.poll(long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	BroadcastMessagePoller.poll(String topic)
List<ConsumeMessage>	DefaultMessagePoller.poll(String topic)
List<ConsumeMessage>	MessagePollerWrapper.poll(String topic)
List<ConsumeMessage>	PartitionMessagePoller.poll(String topic)
List<ConsumeMessage>	BroadcastMessagePoller.poll(String topic, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	DefaultMessagePoller.poll(String topic, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	MessagePollerWrapper.poll(String topic, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	PartitionMessagePoller.poll(String topic, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessageConsumerWrapper.pollAsync()
CompletableFuture<List<ConsumeMessage>>	DefaultMessageConsumer.pollAsync()
CompletableFuture<List<ConsumeMessage>>	MessageConsumerWrapper.pollAsync(long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	DefaultMessageConsumer.pollAsync(long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	BroadcastMessagePoller.pollAsync(String topic)
CompletableFuture<List<ConsumeMessage>>	DefaultMessagePoller.pollAsync(String topic)
CompletableFuture<List<ConsumeMessage>>	MessagePollerWrapper.pollAsync(String topic)
CompletableFuture<List<ConsumeMessage>>	PartitionMessagePoller.pollAsync(String topic)
CompletableFuture<List<ConsumeMessage>>	BroadcastMessagePoller.pollAsync(String topic, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	DefaultMessagePoller.pollAsync(String topic, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessagePollerWrapper.pollAsync(String topic, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	PartitionMessagePoller.pollAsync(String topic, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	MessageConsumerWrapper.pollPartition(short partition)
List<ConsumeMessage>	DefaultMessageConsumer.pollPartition(short partition)
List<ConsumeMessage>	MessageConsumerWrapper.pollPartition(short partition, long index)
List<ConsumeMessage>	DefaultMessageConsumer.pollPartition(short partition, long index)
List<ConsumeMessage>	MessageConsumerWrapper.pollPartition(short partition, long index, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	DefaultMessageConsumer.pollPartition(short partition, long index, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	MessageConsumerWrapper.pollPartition(short partition, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	DefaultMessageConsumer.pollPartition(short partition, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	BroadcastMessagePoller.pollPartition(String topic, short partition)
List<ConsumeMessage>	DefaultMessagePoller.pollPartition(String topic, short partition)
List<ConsumeMessage>	MessagePollerWrapper.pollPartition(String topic, short partition)
List<ConsumeMessage>	PartitionMessagePoller.pollPartition(String topic, short partition)
List<ConsumeMessage>	BroadcastMessagePoller.pollPartition(String topic, short partition, long index)
List<ConsumeMessage>	DefaultMessagePoller.pollPartition(String topic, short partition, long index)
List<ConsumeMessage>	MessagePollerWrapper.pollPartition(String topic, short partition, long index)
List<ConsumeMessage>	PartitionMessagePoller.pollPartition(String topic, short partition, long index)
List<ConsumeMessage>	BroadcastMessagePoller.pollPartition(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	DefaultMessagePoller.pollPartition(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	MessagePollerWrapper.pollPartition(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	PartitionMessagePoller.pollPartition(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	BroadcastMessagePoller.pollPartition(String topic, short partition, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	DefaultMessagePoller.pollPartition(String topic, short partition, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	MessagePollerWrapper.pollPartition(String topic, short partition, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	PartitionMessagePoller.pollPartition(String topic, short partition, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessageConsumerWrapper.pollPartitionAsync(short partition)
CompletableFuture<List<ConsumeMessage>>	DefaultMessageConsumer.pollPartitionAsync(short partition)
CompletableFuture<List<ConsumeMessage>>	MessageConsumerWrapper.pollPartitionAsync(short partition, long index)
CompletableFuture<List<ConsumeMessage>>	DefaultMessageConsumer.pollPartitionAsync(short partition, long index)
CompletableFuture<List<ConsumeMessage>>	MessageConsumerWrapper.pollPartitionAsync(short partition, long index, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	DefaultMessageConsumer.pollPartitionAsync(short partition, long index, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessageConsumerWrapper.pollPartitionAsync(short partition, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	DefaultMessageConsumer.pollPartitionAsync(short partition, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	BroadcastMessagePoller.pollPartitionAsync(String topic, short partition)
CompletableFuture<List<ConsumeMessage>>	DefaultMessagePoller.pollPartitionAsync(String topic, short partition)
CompletableFuture<List<ConsumeMessage>>	MessagePollerWrapper.pollPartitionAsync(String topic, short partition)
CompletableFuture<List<ConsumeMessage>>	PartitionMessagePoller.pollPartitionAsync(String topic, short partition)
CompletableFuture<List<ConsumeMessage>>	BroadcastMessagePoller.pollPartitionAsync(String topic, short partition, long index)
CompletableFuture<List<ConsumeMessage>>	DefaultMessagePoller.pollPartitionAsync(String topic, short partition, long index)
CompletableFuture<List<ConsumeMessage>>	MessagePollerWrapper.pollPartitionAsync(String topic, short partition, long index)
CompletableFuture<List<ConsumeMessage>>	PartitionMessagePoller.pollPartitionAsync(String topic, short partition, long index)
CompletableFuture<List<ConsumeMessage>>	BroadcastMessagePoller.pollPartitionAsync(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	DefaultMessagePoller.pollPartitionAsync(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessagePollerWrapper.pollPartitionAsync(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	PartitionMessagePoller.pollPartitionAsync(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	BroadcastMessagePoller.pollPartitionAsync(String topic, short partition, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	DefaultMessagePoller.pollPartitionAsync(String topic, short partition, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	MessagePollerWrapper.pollPartitionAsync(String topic, short partition, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	PartitionMessagePoller.pollPartitionAsync(String topic, short partition, long timeout, TimeUnit timeoutUnit)

类型变量类型为ConsumeMessage的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)
void	CompletableFuturePollerListener.onMessage(List<ConsumeMessage> messages)

类型变量类型为ConsumeMessage的org.joyqueue.client.internal.consumer.support中的构造器参数

构造器和说明
BatchConsumerInvoker(ConsumerConfig config, TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages, List<BatchMessageListener> listeners)
CompletableFuturePollerListener(CompletableFuture<List<ConsumeMessage>> future)
OnceConsumerInvoker(ConsumerConfig config, TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages, List<MessageListener> listeners)