diff --git a/dtmcli/msg.go b/dtmcli/msg.go
index 7a511b3..492906e 100644
--- a/dtmcli/msg.go
+++ b/dtmcli/msg.go
@@ -22,7 +22,7 @@ type Msg struct {
 
 // NewMsg create new msg
 func NewMsg(server string, gid string) *Msg {
-	return &Msg{TransBase: *dtmimp.NewTransBase(gid, dtmutil.BarrierOpMsg, server, "")}
+	return &Msg{TransBase: *dtmimp.NewTransBase(gid, "msg", server, "")}
 }
 
 // Add add a new step