diff --git a/pkg/node/message.go b/pkg/node/message.go index d2563d0..1a6e59e 100644 --- a/pkg/node/message.go +++ b/pkg/node/message.go @@ -122,7 +122,7 @@ func (message *Message) ParsePayload(target interface{}) error { if message.Payload == nil { return nil } - return json.Unmarshal(message.Payload, target) + return UnmarshalJSON(message.Payload, target) } // --- Payload Types ---