- Fetch (normalized) message headers for most Message* events.
- Store raw message payload as string.
- Insert individual records for each affected message in an event.