Package com.composum.sling.core.concurrent

Class JobMonitor

java.lang.Object

com.composum.sling.core.concurrent.JobMonitor

All Implemented Interfaces:

Callable<Boolean>

Direct Known Subclasses:

JobMonitor.IsDone, JobMonitor.IsStarted

public abstract class JobMonitor
extends Object
implements Callable<Boolean>

Created by rw on 20.04.16.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JobMonitor.IsDone
static class	JobMonitor.IsStarted

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.sling.event.jobs.Job.JobState	currentState
static long	DELAY
protected boolean	done
protected org.apache.sling.event.jobs.Job.JobState	finalState
protected Boolean	isActive
String	jobId
org.apache.sling.event.jobs.JobManager	jobManager
org.apache.sling.api.resource.ResourceResolver	resolver
protected boolean	running
protected long	timeout
protected Boolean	wasActive

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JobMonitor(org.apache.sling.event.jobs.JobManager jobManager, org.apache.sling.api.resource.ResourceResolver resolver, String jobId, Long timeout)

Method Summary

Modifier and Type	Method	Description
Boolean	call()
protected void	checkJobState()
boolean	done()
boolean	error()
@Nullable JobFacade	getJob()
protected abstract boolean	goalReached()
boolean	started()
boolean	stopped()
boolean	succeeded()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

DELAY

public static final long DELAY

See Also:

Constant Field Values

jobManager

public final org.apache.sling.event.jobs.JobManager jobManager

resolver

public final org.apache.sling.api.resource.ResourceResolver resolver

jobId

public final String jobId

isActive

protected Boolean isActive

wasActive

protected Boolean wasActive

currentState

protected org.apache.sling.event.jobs.Job.JobState currentState

finalState

protected org.apache.sling.event.jobs.Job.JobState finalState

running

protected boolean running

done

protected boolean done

timeout

protected long timeout

Constructor Detail

JobMonitor

protected JobMonitor(org.apache.sling.event.jobs.JobManager jobManager,
                     org.apache.sling.api.resource.ResourceResolver resolver,
                     String jobId,
                     Long timeout)

Method Detail

started

public boolean started()

succeeded

public boolean succeeded()

stopped

public boolean stopped()

error

public boolean error()

done

public boolean done()

goalReached

protected abstract boolean goalReached()

call

public Boolean call()

Specified by:

call in interface Callable<Boolean>

getJob

@Nullable
public @Nullable JobFacade getJob()

checkJobState

protected void checkJobState()

toString

public String toString()

Overrides:

toString in class Object