Move catchup of replication streams logic to worker.