protected void init ( ) { log . debug ( "taskworker {} initializing..." , this ) ; scheduleVisibilityTimeoutExtender ( task , new Date ( ) , task . getVisibilityTimeout ( ) ) ; log . debug ( "taskworker {} initialized" , this ) ; initialized = true ; }
This method be called before run since it is possible that there may be significant delay between when the TaskWorker is initialized and when it is executed .