- Add json schema (ideally one schema, but could be multiple) - Add table and entity (we need to store outbound activities, not inbound) - Add worker to ingest from RabbitMQ - Add worker to consumer callback