程序包 com.sie.mbm.mom.framework.mq.async

类 MessageHandlerInfo

java.lang.Object
com.sie.mbm.mom.framework.mq.async.MessageHandlerInfo
public class MessageHandlerInfo extends Object
消息处理器配置信息

  • 字段详细资料

    • topic

      private String topic
      消息的Topic或StreamKey

    • group

      private String group
      消费组

    • consumeThread

      private int consumeThread
      消费线程数

    • maxRetryCount

      private int maxRetryCount
      最大重试次数

    • ackAutoDelMessage

      private boolean ackAutoDelMessage
      redis 专用, 确认消费自动删除消息, 对于只有一个消费者组的消费场景, 消费成功后可以配置删除消息, 减少服务内存占用

    • payloadType

      private Class<?> payloadType
      消息体类型

    • taskHandler

      private MessageHandlerInterface<Object> taskHandler
      消息处理类

  • 构造器详细资料

    • MessageHandlerInfo

      public MessageHandlerInfo()