rocket-mq-springboot-starter/src/main/java/com/njcn/middle/rocket/domain/BaseMessage.java

package com.njcn.middle.rocket.domain;

import cn.hutool.core.util.IdUtil;
import lombok.Data;

import java.time.LocalDateTime;

/**
 * @author hongawen
 * @version 1.0.0
 * @date 2023年08月04日 10:53
 */
@Data
public abstract class BaseMessage {

    /**
     * 业务键，用于RocketMQ控制台查看消费情况
     */
    protected String key = IdUtil.getSnowflake().nextIdStr();

    /**
     * 发送消息来源，用于排查问题
     */
    protected String source = "";

    /**
     * 发送时间
     */
    protected LocalDateTime sendTime = LocalDateTime.now();

    /**
     * 重试次数，用于判断重试次数，超过重试次数发送异常警告
     */
    protected Integer retryTimes = 0;
}