Realtime distributed message processing at scale