Refactor Subscription Processing Scheduling