Refactor getting replication updates from database.