接口的使用
org.joyqueue.client.internal.consumer.MessageListener

使用MessageListener的程序包

程序包	说明
io.openmessaging.joyqueue.consumer.support
org.joyqueue.client.internal.consumer
org.joyqueue.client.internal.consumer.container
org.joyqueue.client.internal.consumer.support

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

实现MessageListener的io.openmessaging.joyqueue.consumer.support中的类

限定符和类型	类和说明
class	MessageListenerAdapter MessageListenerAdapter author: gaohaoxiang date: 2019/2/20

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

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

限定符和类型	方法和说明
void	MessageListenerContainer.addListener(String topic, MessageListener messageListener)
void	MessageConsumer.subscribe(String topic, MessageListener messageListener)

org.joyqueue.client.internal.consumer.container中MessageListener的使用

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

限定符和类型	方法和说明
void	MessageListenerContainerWrapper.addListener(String topic, MessageListener messageListener)
void	DefaultMessageListenerContainer.addListener(String topic, MessageListener messageListener)

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

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

限定符和类型	方法和说明
List<MessageListener>	MessageListenerManager.getListeners()

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

限定符和类型	方法和说明
void	MessageConsumerWrapper.subscribe(String topic, MessageListener messageListener)
void	DefaultMessageConsumer.subscribe(String topic, MessageListener messageListener)

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

限定符和类型	方法和说明
protected List<ConsumeReply>	TopicMessageConsumerDispatcher.doOnceDispatch(TopicMetadata topicMetadata, org.joyqueue.domain.ConsumerPolicy consumerPolicy, List<ConsumeMessage> messages, List<MessageListener> listeners)

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

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