An notification event processing library based on persistent streams.