接口的使用
org.redkale.mq.MessageConsumer

使用MessageConsumer的程序包

程序包	说明
org.redkale.mq.spi

org.redkale.mq.spi中MessageConsumer的使用

类型参数类型为MessageConsumer的org.redkale.mq.spi中的字段

修饰符和类型	字段	说明
protected CopyOnWriteArrayList<MessageConsumer>	MessageAgent.messageConsumerList

返回MessageConsumer的org.redkale.mq.spi中的方法

修饰符和类型	方法	说明
MessageConsumer	MessageAgent.MessageConsumerWrapper.getConsumer()

返回变量类型为MessageConsumer的类型的org.redkale.mq.spi中的方法

修饰符和类型	方法	说明
Class<? extends MessageConsumer>	consumer()

类型变量类型为MessageConsumer的org.redkale.mq.spi中的方法参数

修饰符和类型	方法	说明
protected StringBuilder	MessageAgent.initMessageConsumer(List<MessageConsumer> consumers)
void	MessageAgent.start(List<MessageConsumer> consumers)

参数类型为MessageConsumer的org.redkale.mq.spi中的构造器

构造器	说明
MessageConsumerWrapper(MessageAgent messageAgent, MessageConsumer<T> consumer, String regexTopic, ConvertType convertType)