diff --git a/eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshCommon.java b/eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshCommon.java
index d990c68fed..2a06f262b8 100644
--- a/eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshCommon.java
+++ b/eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshCommon.java
@@ -30,4 +30,6 @@ public class EventMeshCommon {
     public static final int DEFAULT_TIME_OUT_MILLS = 20 * 1000;
 
     public static final String EM_MESSAGE_PROTOCOL_NAME = "eventmeshmessage";
+
+    public static final String OPEN_MESSAGE_PROTOCOL_NAME = "openmessage";
 }
diff --git a/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/MessageUtils.java b/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/MessageUtils.java
index 376121f0e0..8e13f33184 100644
--- a/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/MessageUtils.java
+++ b/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/MessageUtils.java
@@ -45,19 +45,15 @@
 
 public class MessageUtils {
 
-    private static final int SEQ_LENGTH = 10;
-
     /**
      * USERAGENT for PUB
      */
     public static final String USER_AGENT_PURPOSE_PUB = "pub";
-
     /**
      * USERAGENT for SUB
      */
     public static final String USER_AGENT_PURPOSE_SUB = "sub";
-
-    public static final String OPEN_MESSAGE_PROTOCOL_NAME = "openmessage";
+    private static final int SEQ_LENGTH = 10;
 
     public static Package hello(UserAgent user) {
         final Package msg = getPackage(Command.HELLO_REQUEST);
@@ -110,7 +106,7 @@ public static Package buildPackage(Object message, Command command) {
             msg.getHeader().putProperty(Constants.PROTOCOL_DESC, "tcp");
             msg.setBody(message);
         } else if (message instanceof Message) {
-            msg.getHeader().putProperty(Constants.PROTOCOL_TYPE, OPEN_MESSAGE_PROTOCOL_NAME);
+            msg.getHeader().putProperty(Constants.PROTOCOL_TYPE, EventMeshCommon.OPEN_MESSAGE_PROTOCOL_NAME);
             // todo: this version need to be confirmed.
             msg.getHeader().putProperty(Constants.PROTOCOL_VERSION, SpecVersion.V1.toString());
         } else {