@ Override public void executionRecoveryJob ( ) { if ( logger . isDebugEnabled ( ) ) { logger . debug ( "ExecutionRecoveryJob woke up at " + new Date ( ) ) ; } try { executionRecoveryService . doRecovery ( ) ; } catch ( Exception e ) { logger . error ( "Can't run queue recovery job." , e ) ; } }
Job to execute the recovery check .