1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2024-12-14 12:37:31 +00:00

postfixed the reply part of the subject naming instead of having it prefixed

This commit is contained in:
postmannen 2021-06-08 04:45:01 +02:00
parent 6bcb6e95c4
commit 2561c1266c

View file

@ -213,8 +213,8 @@ func (p process) messageDeliverNats(natsConn *nats.Conn, message Message) {
Subject: string(p.subject.name()), Subject: string(p.subject.name()),
// Subject: fmt.Sprintf("%s.%s.%s", proc.node, "command", "CLICommandRequest"), // Subject: fmt.Sprintf("%s.%s.%s", proc.node, "command", "CLICommandRequest"),
// Structure of the reply message are: // Structure of the reply message are:
// reply.<nodename>.<message type>.<method> // <nodename>.<message type>.<method>.reply
Reply: fmt.Sprintf("reply.%s", p.subject.name()), Reply: fmt.Sprintf("%s.reply", p.subject.name()),
Data: dataPayload, Data: dataPayload,
} }