diff --git a/dtmsvr/trans_status.go b/dtmsvr/trans_status.go index 7dc62c9..2c1c16a 100644 --- a/dtmsvr/trans_status.go +++ b/dtmsvr/trans_status.go @@ -99,7 +99,7 @@ func (t *TransGlobal) getURLResult(uri string, branchID, op string, branchPayloa if t.RequestTimeout != 0 { dtmimp.RestyClient.SetTimeout(time.Duration(t.RequestTimeout) * time.Second) } - if t.Protocol == "json-rpc" { + if t.Protocol == "json-rpc" && strings.Contains(uri, "method") { var params map[string]interface{} dtmimp.MustUnmarshal(branchPayload, ¶ms) u, err := url.Parse(uri) diff --git a/test/busi/base_jrpc.go b/test/busi/base_jrpc.go index 91c35f4..56ec9e9 100644 --- a/test/busi/base_jrpc.go +++ b/test/busi/base_jrpc.go @@ -9,7 +9,8 @@ import ( "github.com/gin-gonic/gin" ) -var BusiJrpcUrl = fmt.Sprintf("http://localhost:%d/api/json-rpc?method=", BusiPort) +// BusiJrpcURL url prefix for busi +var BusiJrpcURL = fmt.Sprintf("http://localhost:%d/api/json-rpc?method=", BusiPort) func addJrpcRoute(app *gin.Engine) { app.POST("/api/json-rpc", dtmutil.WrapHandler2(func(c *gin.Context) interface{} { diff --git a/test/msg_jrpc_test.go b/test/msg_jrpc_test.go index 3f86d05..0ee0c23 100644 --- a/test/msg_jrpc_test.go +++ b/test/msg_jrpc_test.go @@ -138,7 +138,7 @@ func genJrpcMsg(gid string) *dtmcli.Msg { req := busi.GenTransReq(30, false, false) msg := dtmcli.NewMsg(dtmutil.DefaultJrpcServer, gid). Add(busi.Busi+"/TransOut", &req). - Add(busi.BusiJrpcUrl+"TransIn", &req) + Add(busi.BusiJrpcURL+"TransIn", &req) msg.QueryPrepared = busi.Busi + "/QueryPrepared" msg.Protocol = dtmimp.Jrpc return msg