From 243610556b929a64de1cb819b5eb07fa1722e88e Mon Sep 17 00:00:00 2001
From: "chen.ma" <machencoding@163.com>
Date: Tue, 7 Dec 2021 23:14:07 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E6=9E=84=E7=9B=91=E6=8E=A7=E4=B8=8A?=
 =?UTF-8?q?=E6=8A=A5=E6=B6=88=E6=81=AF=E5=AE=9E=E4=BD=93.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../common/monitor/AbstractMessage.java       |  4 ++-
 .../cn/hippo4j/common/monitor/Message.java    | 19 +++++++++++++-
 .../common/monitor/MessageWrapper.java        | 25 +++++++++++++++++++
 .../common/monitor/RuntimeMessage.java        |  2 ++
 4 files changed, 48 insertions(+), 2 deletions(-)
 create mode 100644 hippo4j-common/src/main/java/cn/hippo4j/common/monitor/MessageWrapper.java

diff --git a/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/AbstractMessage.java b/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/AbstractMessage.java
index 9d77a37e..c1a0c1fb 100644
--- a/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/AbstractMessage.java
+++ b/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/AbstractMessage.java
@@ -1,6 +1,7 @@
 package cn.hippo4j.common.monitor;
 
 import lombok.Data;
+import lombok.NoArgsConstructor;
 
 import java.util.List;
 
@@ -11,6 +12,7 @@ import java.util.List;
  * @date 2021/12/7 20:31
  */
 @Data
+@NoArgsConstructor
 public abstract class AbstractMessage implements Message {
 
     /**
@@ -21,7 +23,7 @@ public abstract class AbstractMessage implements Message {
     /**
      * messageTypeEnum
      */
-    private MessageTypeEnum messageTypeEnum;
+    private MessageTypeEnum messageType;
 
     /**
      * message
diff --git a/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/Message.java b/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/Message.java
index 02243c8c..309aac76 100644
--- a/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/Message.java
+++ b/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/Message.java
@@ -1,12 +1,15 @@
 package cn.hippo4j.common.monitor;
 
+import java.io.Serializable;
+import java.util.List;
+
 /**
  * Abstract message monitoring interface.
  *
  * @author chen.ma
  * @date 2021/12/6 20:16
  */
-public interface Message {
+public interface Message extends Serializable {
 
     /**
      * Get groupKey.
@@ -15,4 +18,18 @@ public interface Message {
      */
     String getGroupKey();
 
+    /**
+     * Get message type.
+     *
+     * @return
+     */
+    MessageTypeEnum getMessageType();
+
+    /**
+     * Get messages.
+     *
+     * @return
+     */
+    List<Message> getMessages();
+
 }
diff --git a/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/MessageWrapper.java b/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/MessageWrapper.java
new file mode 100644
index 00000000..a786eccf
--- /dev/null
+++ b/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/MessageWrapper.java
@@ -0,0 +1,25 @@
+package cn.hippo4j.common.monitor;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+/**
+ * Message wrapper.
+ *
+ * @author chen.ma
+ * @date 2021/12/7 22:42
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class MessageWrapper extends AbstractMessage implements Serializable {
+
+    /**
+     * messageObj
+     */
+    private Object messageObj;
+
+}
diff --git a/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/RuntimeMessage.java b/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/RuntimeMessage.java
index ab2efe9f..6dc7bd37 100644
--- a/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/RuntimeMessage.java
+++ b/hippo4j-common/src/main/java/cn/hippo4j/common/monitor/RuntimeMessage.java
@@ -1,6 +1,7 @@
 package cn.hippo4j.common.monitor;
 
 import lombok.Data;
+import lombok.NoArgsConstructor;
 
 /**
  * Dynamic thread pool runtime data.
@@ -9,6 +10,7 @@ import lombok.Data;
  * @date 2021/12/6 18:18
  */
 @Data
+@NoArgsConstructor
 public class RuntimeMessage extends AbstractMessage {
 
     /**