org.mmbase.streams.createcaches
Class JobCallable

java.lang.Object
  extended by org.mmbase.streams.createcaches.JobCallable
All Implemented Interfaces:
Callable<Integer>

 class JobCallable
extends Object
implements Callable<Integer>

This is the actual callable that can be submitted to the Executors. It can be submitted multiple times. Until it is ready. It will do that itself, if it detects that the Stage of the job would change. This boils down to iterating the Job.

Version:
$Id: JobCallable.java 41615 2010-03-25 15:14:19Z andre $
Author:
Michiel Meeuwissen

Constructor Summary
JobCallable(Job j, Cloud cloud, ChainedLogger l, int node)
           
 
Method Summary
 Integer call()
           
(package private)  Job getJob()
           
protected  void init()
          Init will wait until the associated source node does actually exist.
 String toString()
           
(package private)  void waitForNode()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

JobCallable

public JobCallable(Job j,
                   Cloud cloud,
                   ChainedLogger l,
                   int node)
Method Detail

getJob

Job getJob()

init

protected void init()
Init will wait until the associated source node does actually exist. It will then also create the related mediafragment.


waitForNode

void waitForNode()
           throws InterruptedException
Throws:
InterruptedException

call

public Integer call()
Specified by:
call in interface Callable<Integer>

toString

public String toString()
Overrides:
toString in class Object


MMBase 2.0-SNAPSHOT - null