| 限定符和类型 | 类和说明 |
|---|---|
class |
BatchMessageListenerAdapter
BatchMessageListenerAdapter
author: gaohaoxiang
date: 2019/2/20
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
MessageListenerContainer.addBatchListener(String topic,
BatchMessageListener messageListener) |
void |
MessageConsumer.subscribeBatch(String topic,
BatchMessageListener batchMessageListener) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
MessageListenerContainerWrapper.addBatchListener(String topic,
BatchMessageListener messageListener) |
void |
DefaultMessageListenerContainer.addBatchListener(String topic,
BatchMessageListener messageListener) |
| 限定符和类型 | 方法和说明 |
|---|---|
List<BatchMessageListener> |
MessageListenerManager.getBatchListeners() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
MessageConsumerWrapper.subscribeBatch(String topic,
BatchMessageListener batchMessageListener) |
void |
DefaultMessageConsumer.subscribeBatch(String topic,
BatchMessageListener batchMessageListener) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected List<ConsumeReply> |
TopicMessageConsumerDispatcher.doBatchDispatch(TopicMetadata topicMetadata,
org.joyqueue.domain.ConsumerPolicy consumerPolicy,
List<ConsumeMessage> messages,
List<BatchMessageListener> listeners) |
| 构造器和说明 |
|---|
BatchConsumerInvoker(ConsumerConfig config,
TopicMetadata topicMetadata,
org.joyqueue.domain.ConsumerPolicy consumerPolicy,
List<ConsumeMessage> messages,
List<BatchMessageListener> listeners) |
Copyright © 2020 Joyqueue Community. All rights reserved.