add fit logic for msgpack

DMwangnima · Dec 29, 2023 · 82d4b56 · 82d4b56
1 parent 1b2a136
commit 82d4b56
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/protocol/triple/client.go b/protocol/triple/client.go
@@ -144,6 +144,8 @@ func newClientManager(url *common.URL) (*clientManager, error) {
 		cliOpts = append(cliOpts, tri.WithProtoJSON())
 	case constant.Hessian2Serialization:
 		cliOpts = append(cliOpts, tri.WithHessian2())
+	case constant.MsgpackSerialization:
+		cliOpts = append(cliOpts, tri.WithMsgPack())
 	default:
 		panic(fmt.Sprintf("Unsupported serialization: %s", serialization))
 	}

diff --git a/protocol/triple/server.go b/protocol/triple/server.go
@@ -73,6 +73,7 @@ func (s *Server) Start(invoker protocol.Invoker, info *server.ServiceInfo) {
 	case constant.ProtobufSerialization:
 	case constant.JSONSerialization:
 	case constant.Hessian2Serialization:
+	case constant.MsgpackSerialization:
 	default:
 		panic(fmt.Sprintf("Unsupported serialization: %s", serialization))
 	}
@@ -134,6 +135,7 @@ func (s *Server) RefreshService(invoker protocol.Invoker, info *server.ServiceIn
 	case constant.ProtobufSerialization:
 	case constant.JSONSerialization:
 	case constant.Hessian2Serialization:
+	case constant.MsgpackSerialization:
 	default:
 		panic(fmt.Sprintf("Unsupported serialization: %s", serialization))
 	}