Function parsePayload

consumer.go:678–686

(pgMsg pgMessage)

		once:                sync.Once{},
		ackFn:               c.ackMessage(c.db, pgMsg.ID),
		nackFn:              c.nackMessage(c.db, pgMsg.ID),
		discardFn:           c.discardMessage(c.db, pgMsg.ID),
		updateLockedUntilFn: c.updateLockedUntil(c.db, pgMsg.ID),
	}
	var err error
	msg.Payload, err = parsePayload(pgMsg)
	if err != nil {
		return msg, errors.Wrap(err, "parsing payload")
	}
	msg.Metadata, err = parseMetadata(pgMsg)
	if err != nil {
		return msg, errors.Wrap(err, "parsing metadata")