Implemented a replay-aware event listener cluster