From 152781b05131e48bf6e94d71cc72dd54af52a3fb Mon Sep 17 00:00:00 2001
From: houzhongjian <houzhongyi@126.com>
Date: 星期四, 10 四月 2025 14:13:29 +0800
Subject: [PATCH] 恢复iailab-framework
---
iailab-framework/iailab-common-mq/src/main/java/com/iailab/framework/mq/redis/core/message/AbstractRedisMessage.java | 29 +++++++++++++++++++++++++++++
1 files changed, 29 insertions(+), 0 deletions(-)
diff --git a/iailab-framework/iailab-common-mq/src/main/java/com/iailab/framework/mq/redis/core/message/AbstractRedisMessage.java b/iailab-framework/iailab-common-mq/src/main/java/com/iailab/framework/mq/redis/core/message/AbstractRedisMessage.java
new file mode 100644
index 0000000..46b3f88
--- /dev/null
+++ b/iailab-framework/iailab-common-mq/src/main/java/com/iailab/framework/mq/redis/core/message/AbstractRedisMessage.java
@@ -0,0 +1,29 @@
+package com.iailab.framework.mq.redis.core.message;
+
+import lombok.Data;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Redis 消息抽象基类
+ *
+ * @author iailab
+ */
+@Data
+public abstract class AbstractRedisMessage {
+
+ /**
+ * 头
+ */
+ private Map<String, String> headers = new HashMap<>();
+
+ public String getHeader(String key) {
+ return headers.get(key);
+ }
+
+ public void addHeader(String key, String value) {
+ headers.put(key, value);
+ }
+
+}
--
Gitblit v1.9.3