(b json.RawMessage)
| 700 | } |
| 701 | if !isJSONObject(pgMsg.Payload) { |
| 702 | return nil, errors.New("payload is invalid JSON object") |
| 703 | } |
| 704 | return pgMsg.Payload, nil |
| 705 | } |
| 706 | |
| 707 | func parseMetadata(pgMsg pgMessage) (map[string]string, error) { |
| 708 | if pgMsg.Metadata == nil { |
| 709 | return map[string]string{}, nil |
| 710 | } |
| 711 | var m map[string]string |
| 712 | if err := json.Unmarshal(pgMsg.Metadata, &m); err != nil { |
no outgoing calls
no test coverage detected