org.mmbase.streams.createcaches
Class JobCallable

java.lang.Object
  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