realtime distributed message processing at scale