Added distributed event cleanup when we get our stream events