From 209fb572bea1e5c927336ca0dba1221e97f37b75 Mon Sep 17 00:00:00 2001 From: postmannen Date: Fri, 18 Feb 2022 05:22:53 +0100 Subject: [PATCH] added fromNode to the nats header --- process.go | 1 + 1 file changed, 1 insertion(+) diff --git a/process.go b/process.go index dd43d4e..3fa27fd 100644 --- a/process.go +++ b/process.go @@ -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 // various configuration options chosen. natsMsgHeader := make(nats.Header) + natsMsgHeader["fromNode"] = []string{string(p.node)} // The serialized value of the nats message payload var natsMsgPayloadSerialized []byte