Rewrite stream queue with worker api.