@ SuppressWarnings ( "unchecked" ) public void runDeadlockFuture ( Runnable deadlockGuardTask ) { if ( deadlockFuture == null ) { ThreadPoolTaskScheduler deadlockGuard = conn . getDeadlockGuardScheduler ( ) ; if ( deadlockGuard != null ) { try { deadlockFuture = ( ScheduledFuture < Runnable > ) deadlockGuard . schedule ( deadlockGuardTask , new Date ( packet . getExpirationTime ( ) ) ) ; } catch ( TaskRejectedException e ) { log . warn ( "DeadlockGuard task is rejected for {}" , sessionId , e ) ; } } else { log . debug ( "Deadlock guard is null for {}" , sessionId ) ; } } else { log . warn ( "Deadlock future is already create for {}" , sessionId ) ; } }
Runs deadlock guard task