package com.ycl.jxkg.rabbitmq;

import lombok.Data;
import org.springframework.amqp.rabbit.connection.CorrelationData;

/**
 * 扩展关联数据
 *
 * @author xp
 * @data 2023/11/11
 */
@Data
public class MyCorrelationData extends CorrelationData {

    /**
     * 消息类型，可用于业务处理
     */
    private RabbitMqMsgTypeEnum msgType;


    public MyCorrelationData(String id, RabbitMqMsgTypeEnum msgType) {
        super(id);
        this.msgType = msgType;
    }


}