fix: send nats msg correctly

jiyeyuran · jiyeyuran · commit ee43565a9750 · 2025-05-29T18:21:10.000+08:00
diff --git a/transport/nats/nats.go b/transport/nats/nats.go
@@ -234,9 +234,9 @@ func (n *ntportSocket) Send(m *transport.Message) error {
 	}
 
 	msg := &nats.Msg{
-		Reply:  n.m.Reply,
-		Header: header,
-		Data:   m.Body,
+		Subject: n.m.Reply,
+		Header:  header,
+		Data:    m.Body,
 	}
 
 	// no deadline

Original file line number	Diff line number	Diff line change
`@@ -234,9 +234,9 @@ func (n ntportSocket) Send(m transport.Message) error {`
`234`	`234`	`}`
`235`	`235`
`236`	`236`	`msg := &nats.Msg{`
`237`		`- Reply: n.m.Reply,`
`238`		`- Header: header,`
`239`		`- Data: m.Body,`
	`237`	`+ Subject: n.m.Reply,`
	`238`	`+ Header: header,`
	`239`	`+ Data: m.Body,`
`240`	`240`	`}`
`241`	`241`
`242`	`242`	`// no deadline`