diff --git a/rpc/server.go b/rpc/server.go index 421ebab..652d571 100644 --- a/rpc/server.go +++ b/rpc/server.go @@ -2,6 +2,7 @@ package rpc import ( "context" + "fmt" "net" "strings" "sync" @@ -97,8 +98,8 @@ func (s *Server) Send(ctx context.Context, in *proto.NotificationRequest) (*prot if in.Data != nil { notification.Data = map[string]interface{}{} - for k, v := range in.Data.Fields { - notification.Data[k] = v + for k, v := range in.Data.AsMap() { + notification.Data[k] = fmt.Sprintf("%v", v) } }