package com.hdkj.lt.core.mq.model;

import com.aliyun.openservices.ons.api.SendCallback;
import com.hdkj.lt.core.mq.callback.PrintLogSendCallback;
import lombok.*;
import lombok.experimental.Accessors;
import lombok.experimental.SuperBuilder;

/**
 * @Description: RocketMQ信息体
 * @Author: wenhao
 * @Create: 2024/06/06 9:15
 * @Version: 1.0
 */
@Getter
@Setter
@SuperBuilder
@NoArgsConstructor
@AllArgsConstructor
@Accessors(chain = true)
@ToString(callSuper = true)
@EqualsAndHashCode
public class RocketMQMessageEntity {

    private String topicId; //订阅主题ID

    private String tag; //标签

    private Object body; //消息内容主体

    private String cacheKey; //缓存key

    private SendCallback sendCallback = new PrintLogSendCallback(); //发送消息后的回调类，默认使用打印日志的

}
