diff --git a/jetstream.go b/jetstream.go index 47ef4ad..a25cca3 100644 --- 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)