RocketMQMessageListener参数

2021-12-28  本文已影响0人  shark没有辣椒

version 4.6

  1. consumerGroup 消费者分组

  2. topic 主题

  3. selectorType 消息选择器类型
    默认值 SelectorType.TAG 根据TAG选择
    仅支持表达式格式如:“tag1 || tag2 || tag3”,如果表达式为null或者“*”标识订阅所有消息
    SelectorType.SQL92 根据SQL92表达式选择

  4. consumeMode 消费模式
    默认值 ConsumeMode.CONCURRENTLY 并行处理
    ConsumeMode.ORDERLY 按顺序处理

  5. messageModel 消息模型
    默认值 MessageModel.CLUSTERING 集群
    MessageModel.BROADCASTING 广播

  6. consumeThreadMax 最大线程数
    默认值 64

  7. consumeTimeout 超时时间
    默认值 30000ms

  8. accessKey
    默认值 ${rocketmq.consumer.access-key:}

  9. secretKey
    默认值 ${rocketmq.consumer.secret-key:}

  10. enableMsgTrace 启用消息轨迹
    默认值 true

  11. customizedTraceTopic 自定义的消息轨迹主题
    默认值 ${rocketmq.consumer.customized-trace-topic:}
    没有配置此配置项则使用默认的主题

  12. nameServer 命名服务器地址
    默认值 ${rocketmq.name-server:}

  13. accessChannel
    默认值 ${rocketmq.access-channel:}


本文转载自https://blog.csdn.net/zhoudingding/article/details/106942574

上一篇下一篇

猜你喜欢

热点阅读