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

added fromNode to the nats header

Browse source
This commit is contained in:
postmannen 2022-02-18 05:22:53 +01:00
parent 34c30d492d
commit 209fb572be
1 changed files with 1 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
process.go
View file

@ -618,6 +618,7 @@ func (p process) publishAMessage(m Message, zEnc *zstd.Encoder, once sync.Once,
// Create the initial header, and set values below depending on the // Create the initial header, and set values below depending on the
// various configuration options chosen. // various configuration options chosen.
natsMsgHeader := make(nats.Header) natsMsgHeader := make(nats.Header)
natsMsgHeader["fromNode"] = []string{string(p.node)}
// The serialized value of the nats message payload // The serialized value of the nats message payload
var natsMsgPayloadSerialized []byte var natsMsgPayloadSerialized []byte