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 ; } }
Clear all scheduled waiting jobs