diff --git a/server_reqres.go b/server_reqres.go index 72c2325..19b8116 100644 --- a/server_reqres.go +++ b/server_reqres.go @@ -30,12 +30,17 @@ func (s Server) Request(subject string, payload []byte) (*nats.Msg, error) { // RequestWithBindData ... func (s Server) RequestWithBindData(subject string, payload []byte, result interface{}) error { msg, err := s.Request(subject, payload) + fmt.Println("data", msg.Data) + fmt.Println("err", err.Error()) if msg == nil || err != nil { + fmt.Println("1") return err } + fmt.Println("2") + // map - return BytesToInterface(msg.Data, &result) + return BytesToInterface(msg.Data, result) } // Reply ... diff --git a/utils.go b/utils.go index c4d106a..ed090fb 100644 --- a/utils.go +++ b/utils.go @@ -46,7 +46,7 @@ func InterfaceToBytes(data interface{}) []byte { } func BytesToInterface(b []byte, dest interface{}) error { - err := json.Unmarshal(b, dest) + err := json.Unmarshal(b, &dest) if err != nil { fmt.Printf("[natsio.BytesToInterface] error: %v with data: %s\n", err, string(b)) }