Stream filtering moved to rivus_cep_query.erl