From c688fd3cf7f3ed0cc416d82282d23ddc44506d41 Mon Sep 17 00:00:00 2001
From: fuwenkai <834260992@qq.com>
Date: Wed, 18 Oct 2023 15:37:52 +0800
Subject: [PATCH] [INLONG-9070][Manager] Add MessageWrapType.forType method for
 MessageWrapType

---
 .../apache/inlong/common/enums/MessageWrapType.java   | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/inlong-common/src/main/java/org/apache/inlong/common/enums/MessageWrapType.java b/inlong-common/src/main/java/org/apache/inlong/common/enums/MessageWrapType.java
index 159c081c563..8733858c2da 100644
--- a/inlong-common/src/main/java/org/apache/inlong/common/enums/MessageWrapType.java
+++ b/inlong-common/src/main/java/org/apache/inlong/common/enums/MessageWrapType.java
@@ -17,6 +17,8 @@
 
 package org.apache.inlong.common.enums;
 
+import java.util.Objects;
+
 /**
  * Enumeration class of encoding format of data output from DataProxy to MQ
  */
@@ -58,6 +60,15 @@ public static MessageWrapType valueOf(int value) {
         return UNKNOWN;
     }
 
+    public static MessageWrapType forType(String type) {
+        for (MessageWrapType msgEncType : MessageWrapType.values()) {
+            if (Objects.equals(msgEncType.getName(), type)) {
+                return msgEncType;
+            }
+        }
+        return UNKNOWN;
+    }
+
     private final int id;
     private final String name;
     private final String desc;