test recvSub msg

liuxiaolong

2021-09-07 d3865ba32965a327efcfea052ccac16864cfc71c

 requestTopic.go

@@ -1,8 +1,13 @@
package bhomeclient

type MicroFunc func(req *Request) *Reply
type WrapperHandler struct {
   Bk       Broker
   Tr       Transport
}

type MicroFunc func(h *WrapperHandler, req *Request) *Reply


type Transport interface {
   RequestTopic(string, Request) (*Reply,error)
   RequestTopic(string, Request, int) (*Reply,error)
}