1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
| 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;
| }
|
|
| }
|
|
