A real time event processing engine