增加代码

cmd/static/main.go

@@ -41,6 +41,11 @@ type RecvPro struct {
 
 }
 
+func (t *RecvPro) FailAction([]byte) error {
+	fmt.Print(1)
+	panic("implement me")
+}
+
 type RabbitMsg struct {
 	ComCreditsId 	string `json:"com_credits_id"`
 	ErpCompanyCode  string `json:"erp_company_code"`

go.mod

@@ -4,6 +4,7 @@ go 1.12
 
 require (
 	github.com/bilibili/kratos v0.3.1
+	github.com/ichunt2019/go-msgserver v0.0.0-20191205082056-967d5dbbe7cd
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/pkg/errors v0.8.1
 )

go.sum

@@ -92,8 +92,6 @@ github.com/grpc-ecosystem/grpc-gateway v1.9.5/go.mod h1:vNeuVxBJEsws4ogUvrchl83t
 github.com/hashicorp/go-uuid v1.0.1/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro=
 github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ=
 github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
-github.com/ichunt2019/go-msgserver v0.0.0-20191204053231-bd327f4f8ff1 h1:UK7gMV/AS+d3p0wFQLXndXyek3FUIYxUZjPTyx4tZ2g=
-github.com/ichunt2019/go-msgserver v0.0.0-20191204053231-bd327f4f8ff1/go.mod h1:fWAvbry0W9nhmkqgT2agwRqYCWlguUJXgy2rgoWOUmA=
 github.com/ichunt2019/go-msgserver v0.0.0-20191205082056-967d5dbbe7cd h1:H9X0AQdmFig5ywAQiRLaZgOLoGf2NnlbqN8XT34dbp4=
 github.com/ichunt2019/go-msgserver v0.0.0-20191205082056-967d5dbbe7cd/go.mod h1:fWAvbry0W9nhmkqgT2agwRqYCWlguUJXgy2rgoWOUmA=
 github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8=