RocketMQMessageListener参数
version 4.6
-
consumerGroup 消费者分组
-
topic 主题
-
selectorType 消息选择器类型
默认值 SelectorType.TAG 根据TAG选择
仅支持表达式格式如:“tag1 || tag2 || tag3”,如果表达式为null或者“*”标识订阅所有消息
SelectorType.SQL92 根据SQL92表达式选择 -
consumeMode 消费模式
默认值 ConsumeMode.CONCURRENTLY 并行处理
ConsumeMode.ORDERLY 按顺序处理 -
messageModel 消息模型
默认值 MessageModel.CLUSTERING 集群
MessageModel.BROADCASTING 广播 -
consumeThreadMax 最大线程数
默认值 64 -
consumeTimeout 超时时间
默认值 30000ms -
accessKey
默认值 ${rocketmq.consumer.access-key:} -
secretKey
默认值 ${rocketmq.consumer.secret-key:} -
enableMsgTrace 启用消息轨迹
默认值 true -
customizedTraceTopic 自定义的消息轨迹主题
默认值 ${rocketmq.consumer.customized-trace-topic:}
没有配置此配置项则使用默认的主题 -
nameServer 命名服务器地址
默认值 ${rocketmq.name-server:} -
accessChannel
默认值 ${rocketmq.access-channel:}
本文转载自https://blog.csdn.net/zhoudingding/article/details/106942574