JobManager cleanup and the callback that invokes it

gistfile1.java

public class JobManagerImpl implements JobManager {
    private final JobManager self = TypedActor.<JobManager>self();
    private final Promise<String> completion;
    
    public JobManager(Promise<String> completion) {
        this.completion = completion;
        completion.future().onComplete(new OnComplete<String>() {
		@Override
			public void onComplete(Throwable arg0, String arg1) {
				self.cleanup();
			}
		}, TypedActor.dispatcher());
    }
    
    public void cleanup() {
        if(completion.isCompleted()) {
            immutable.batchManager().nextBatch();
            jobQueue.clear();
            for(ActorRef child : JavaConversions.asJavaIterable(TypedActor.context().children())) {
			    TypedActor.context().stop(child);
		    }
	    }
	}
}