Refactor fanout logic into ProcessContinuousQueries()