package com.walker.queue;

import com.walker.infrastructure.utils.DateUtils;
import com.walker.infrastructure.utils.StringUtils;

/**
 * 消息实体，所有队列消息都需要继承此类。
 * @author 时克英
 * @date 2023-09-18
 */
public abstract class MqBaseMessage {

    /**
     * 业务键，用于RocketMQ控制台查看消费情况
     * @return
     */
    public String getKey() {
        return key;
    }

    public void setKey(String key) {
        this.key = key;
    }

    /**
     * 发送消息来源，用于排查问题
     * @return
     */
    public String getSource() {
        return source;
    }

    public void setSource(String source) {
        this.source = source;
    }

    /**
     * 发送时间，格式：20230919155102
     * @return
     */
    public long getSendTime() {
        return sendTime;
    }

    public void setSendTime(long sendTime) {
        this.sendTime = sendTime;
    }

    /**
     * 重试次数。
     * @return
     */
    public int getRetryTimes() {
        return retryTimes;
    }

    public void setRetryTimes(int retryTimes) {
        this.retryTimes = retryTimes;
    }

    /**
     * 返回消息主题，由发送方提供。
     * @return
     */
    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    protected String topic;

    /**
     * 业务键，用于RocketMQ控制台查看消费情况
     */
    protected String key;
    /**
     * 发送消息来源，用于排查问题
     */
    protected String source = StringUtils.EMPTY_STRING;

    /**
     * 发送时间
     */
    protected long sendTime = DateUtils.getDateTimeNumber();

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

    @Override
    public String toString() {
        return "MqBaseMessage{" +
                "key='" + key + '\'' +
                ", source='" + source + '\'' +
                ", sendTime=" + sendTime +
                ", retryTimes=" + retryTimes +
                ", topic=" + topic +
                '}';
    }
}