public synchronized void fireEvaluatorAllocatedEvent ( ) { if ( this . stateManager . isAllocated ( ) && this . allocationNotFired ) { final AllocatedEvaluator allocatedEvaluator = new AllocatedEvaluatorImpl ( this , this . remoteManager . getMyIdentifier ( ) , this . configurationSerializer , getJobIdentifier ( ) , this . loggingScopeFactory , this . evaluatorConfigurationProviders ) ; LOG . log ( Level . FINEST , "Firing AllocatedEvaluator event for Evaluator with ID [{0}]" , this . evaluatorId ) ; this . messageDispatcher . onEvaluatorAllocated ( allocatedEvaluator ) ; this . allocationNotFired = false ; } else { LOG . log ( Level . WARNING , "AllocatedEvaluator event fired more than once." ) ; } }
Fires the EvaluatorAllocatedEvent to the handlers . Can only be done once .