Package org.apache.ofbiz.service.job

Class PersistedServiceJob

java.lang.Object

org.apache.ofbiz.service.job.AbstractJob

org.apache.ofbiz.service.job.GenericServiceJob

org.apache.ofbiz.service.job.PersistedServiceJob

All Implemented Interfaces:

Serializable, Runnable, Job

public class PersistedServiceJob
extends GenericServiceJob

A Job that is backed by the entity engine. Job data is stored in the JobSandbox entity.

When the job is queued, this object "owns" the entity value. Any external changes are ignored except the cancelDateTime field - jobs can be canceled after they are queued.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ofbiz.service.job.Job

Job.State

Constructor Summary

Constructors

Constructor	Description
PersistedServiceJob(DispatchContext dctx, GenericValue jobValue, GenericRequester req)	Creates a new PersistedServiceJob

Method Summary

Modifier and Type	Method	Description
void	deQueue()	Transitions this job to the pre-queued (created) state.
protected void	failed(Throwable t)	Method is called when the service fails.
protected void	finish(Map<String,Object> result)	Method is called after the service has finished successfully.
protected Map<String,Object>	getContext()	Gets the context for the service invocation.
long	getPriority()	Returns the priority of this job, higher the number the higher the priority
protected String	getServiceName()	Gets the name of the service as defined in the definition file.
Date	getStartTime()	Returns the time this job is scheduled to start.
protected void	init()	Method is called prior to running the service.
void	queue()	Transitions this job to the queued state.

Methods inherited from class org.apache.ofbiz.service.job.GenericServiceJob

exec, getDctx, isValid

Methods inherited from class org.apache.ofbiz.service.job.AbstractJob

currentState, getCurrentState, getJobId, getJobName, getRuntime, run, setCurrentState

Methods inherited from class java.lang.Object

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

Constructor Details

PersistedServiceJob

public PersistedServiceJob(DispatchContext dctx,
 GenericValue jobValue,
 GenericRequester req)

Creates a new PersistedServiceJob

Parameters:

dctx -

jobValue -

req -

Method Details

queue

public void queue()
           throws InvalidJobException

Description copied from interface: Job

Transitions this job to the queued state.

Specified by:

queue in interface Job

Overrides:

queue in class AbstractJob

Throws:

InvalidJobException

init

protected void init()
             throws InvalidJobException

Description copied from class: GenericServiceJob

Method is called prior to running the service.

Overrides:

init in class GenericServiceJob

Throws:

InvalidJobException

finish

protected void finish(Map<String,Object> result)
               throws InvalidJobException

Description copied from class: GenericServiceJob

Method is called after the service has finished successfully.

Overrides:

finish in class GenericServiceJob

Throws:

InvalidJobException

failed

protected void failed(Throwable t)
               throws InvalidJobException

Description copied from class: GenericServiceJob

Method is called when the service fails.

Overrides:

failed in class GenericServiceJob

Parameters:

t - Throwable

Throws:

InvalidJobException

getServiceName

protected String getServiceName()

Description copied from class: GenericServiceJob

Gets the name of the service as defined in the definition file.

Overrides:

getServiceName in class GenericServiceJob

Returns:

The name of the service to be invoked.

getContext

protected Map<String,Object> getContext()
                                 throws InvalidJobException

Description copied from class: GenericServiceJob

Gets the context for the service invocation.

Overrides:

getContext in class GenericServiceJob

Returns:

Map of name value pairs making up the service context.

Throws:

InvalidJobException

deQueue

public void deQueue()
             throws InvalidJobException

Description copied from interface: Job

Transitions this job to the pre-queued (created) state. The job manager will call this method when there was a problem adding this job to the queue.

Specified by:

deQueue in interface Job

Overrides:

deQueue in class GenericServiceJob

Throws:

InvalidJobException

getStartTime

public Date getStartTime()

Description copied from interface: Job

Returns the time this job is scheduled to start.

Specified by:

getStartTime in interface Job

Overrides:

getStartTime in class AbstractJob

getPriority

public long getPriority()

Description copied from interface: Job

Returns the priority of this job, higher the number the higher the priority

Specified by:

getPriority in interface Job

Overrides:

getPriority in class AbstractJob