diff --git a/process.go b/process.go index bcd3ff8..ce7ad9f 100644 --- a/process.go +++ b/process.go @@ -213,8 +213,8 @@ func (p process) messageDeliverNats(natsConn *nats.Conn, message Message) { Subject: string(p.subject.name()), // Subject: fmt.Sprintf("%s.%s.%s", proc.node, "command", "CLICommandRequest"), // Structure of the reply message are: - // reply... - Reply: fmt.Sprintf("reply.%s", p.subject.name()), + // ...reply + Reply: fmt.Sprintf("%s.reply", p.subject.name()), Data: dataPayload, }