code: private void clearWaitJobs() {
          log.debug("Clear wait jobs");
          if (pullAndPush != null) {
              subscriberStream.cancelJob(pullAndPush);
              releasePendingMessage();
              pullAndPush = null;
          }
          if (waitLiveJob != null) {
              schedulingService.removeScheduledJob(waitLiveJob);
              waitLiveJob = null;
          }
      }
docs: Clear all scheduled waiting jobs