Package org.apache.ofbiz.service.job

Class GenericServiceJob

java.lang.Object

org.apache.ofbiz.service.job.AbstractJob

org.apache.ofbiz.service.job.GenericServiceJob

All Implemented Interfaces:

Serializable, Runnable, Job

Direct Known Subclasses:

PersistedServiceJob

public class GenericServiceJob
extends AbstractJob
implements Serializable

A generic async-service job.

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
GenericServiceJob(DispatchContext dctx, String jobId, String jobName, String service, Map<String,Object> context, GenericRequester req)

Method Summary

Modifier and Type	Method	Description
void	deQueue()	Transitions this job to the pre-queued (created) state.
void	exec()	Invokes the service.
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.
DispatchContext	getDctx()	Gets dctx.
protected String	getServiceName()	Gets the name of the service as defined in the definition file.
protected void	init()	Method is called prior to running the service.
boolean	isValid()	Returns true if this job is ready to be queued.

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

currentState, getCurrentState, getJobId, getJobName, getPriority, getRuntime, getStartTime, queue, run, setCurrentState

Methods inherited from class java.lang.Object

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

Constructor Details

GenericServiceJob

public GenericServiceJob(DispatchContext dctx,
 String jobId,
 String jobName,
 String service,
 Map<String,Object> context,
 GenericRequester req)

Method Details

getDctx

public DispatchContext getDctx()

Gets dctx.

Returns:

the dctx

exec

public void exec()
          throws InvalidJobException

Invokes the service.

Specified by:

exec in class AbstractJob

Throws:

InvalidJobException

init

protected void init()
             throws InvalidJobException

Method is called prior to running the service.

Throws:

InvalidJobException

finish

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

Method is called after the service has finished successfully.

Throws:

InvalidJobException

failed

protected void failed(Throwable t)
               throws InvalidJobException

Method is called when the service fails.

Parameters:

t - Throwable

Throws:

InvalidJobException

getContext

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

Gets the context for the service invocation.

Returns:

Map of name value pairs making up the service context.

Throws:

InvalidJobException

getServiceName

protected String getServiceName()

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

Returns:

The name of the service to be invoked.

isValid

public boolean isValid()

Description copied from interface: Job

Returns true if this job is ready to be queued.

Specified by:

isValid in interface Job

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 AbstractJob

Throws:

InvalidJobException