hotfix: add log payload to help development (#17)

kumparan · Oct 11, 2022 · fe309a9 · fe309a9
1 parent 23c0bdd
commit fe309a9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/jetstream.go b/jetstream.go
@@ -111,6 +111,7 @@ func NewNATSMessageHandler(payload MessageParser, retryAttempts int, retryInterv
 		}
 
 		payload.AddSubject(msg.Subject)
+		defer logger.WithField("payload", utils.Dump(payload)).Warn("message payload")
 
 		retryErr := utils.Retry(retryAttempts, retryInterval, func() error {
 			return msgHandler(payload)