Add replay-related logic to domain repository and redis event bus