public abstract class JobEntity extends Object implements Serializable, Job, PersistentObject, HasRevision
TimerEntity or MessageEntity.| Modifier and Type | Field and Description |
|---|---|
static boolean |
DEFAULT_EXCLUSIVE |
static int |
DEFAULT_RETRIES |
protected String |
deploymentId |
protected Date |
duedate |
protected ByteArrayEntity |
exceptionByteArray |
protected String |
exceptionByteArrayId |
protected String |
exceptionMessage |
protected String |
executionId |
protected String |
id |
protected boolean |
isExclusive |
protected String |
jobHandlerConfiguration |
protected String |
jobHandlerType |
protected Date |
lockExpirationTime |
protected String |
lockOwner |
protected String |
processInstanceId |
protected int |
retries |
protected int |
revision |
| Constructor and Description |
|---|
JobEntity() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
createFailedJobIncident() |
void |
delete() |
void |
execute(CommandContext commandContext) |
String |
getDeploymentId()
Returns the id of the deployment in which context the job was created.
|
Date |
getDuedate()
Returns the date on which this job is supposed to be processed.
|
String |
getExceptionByteArrayId() |
String |
getExceptionMessage()
Returns the message of the exception that occurred, the last time the job was
executed.
|
String |
getExceptionStacktrace() |
String |
getExecutionId()
Returns the specific execution on which the job was created.
|
String |
getId()
Returns the unique identifier for this job.
|
String |
getJobHandlerConfiguration() |
String |
getJobHandlerType() |
Date |
getLockExpirationTime() |
String |
getLockOwner() |
Object |
getPersistentState()
Returns a representation of the object,
as would be stored in the database.
|
String |
getProcessInstanceId()
Returns the id of the process instance which execution created the job.
|
int |
getRetries()
Returns the number of retries this job has left.
|
int |
getRevision() |
int |
getRevisionNext() |
void |
insert() |
boolean |
isExclusive() |
protected void |
removeFailedJobIncident() |
void |
setDeploymentId(String deploymentId) |
void |
setDuedate(Date duedate) |
void |
setExceptionMessage(String exceptionMessage) |
void |
setExceptionStacktrace(String exception) |
void |
setExclusive(boolean isExclusive) |
void |
setExecution(ExecutionEntity execution) |
void |
setExecutionId(String executionId) |
void |
setId(String id) |
void |
setJobHandlerConfiguration(String jobHandlerConfiguration) |
void |
setJobHandlerType(String jobHandlerType) |
void |
setLockExpirationTime(Date claimedUntil) |
void |
setLockOwner(String claimedBy) |
void |
setProcessInstanceId(String processInstanceId) |
void |
setRetries(int retries) |
void |
setRetriesFromPersistence(int retries) |
void |
setRevision(int revision) |
String |
toString() |
public static final boolean DEFAULT_EXCLUSIVE
public static final int DEFAULT_RETRIES
protected String id
protected int revision
protected Date duedate
protected String lockOwner
protected Date lockExpirationTime
protected String executionId
protected String processInstanceId
protected boolean isExclusive
protected int retries
protected String jobHandlerType
protected String jobHandlerConfiguration
protected ByteArrayEntity exceptionByteArray
protected String exceptionByteArrayId
protected String exceptionMessage
protected String deploymentId
public void execute(CommandContext commandContext)
public void insert()
public void delete()
public Object getPersistentState()
PersistentObjectgetPersistentState in interface PersistentObjectpublic int getRevisionNext()
getRevisionNext in interface HasRevisionpublic void setExecution(ExecutionEntity execution)
public String getExecutionId()
JobgetExecutionId in interface Jobpublic void setExecutionId(String executionId)
public int getRetries()
JobgetRetries in interface Jobpublic void setRetries(int retries)
public void setRetriesFromPersistence(int retries)
protected void createFailedJobIncident()
protected void removeFailedJobIncident()
public String getExceptionStacktrace()
public String getLockOwner()
public void setLockOwner(String claimedBy)
public Date getLockExpirationTime()
public void setLockExpirationTime(Date claimedUntil)
public String getProcessInstanceId()
JobgetProcessInstanceId in interface Jobpublic void setProcessInstanceId(String processInstanceId)
public boolean isExclusive()
public void setExclusive(boolean isExclusive)
public String getId()
JobgetId in interface PersistentObjectgetId in interface Jobpublic void setId(String id)
setId in interface PersistentObjectpublic Date getDuedate()
JobgetDuedate in interface Jobpublic void setDuedate(Date duedate)
public void setExceptionStacktrace(String exception)
public String getJobHandlerType()
public void setJobHandlerType(String jobHandlerType)
public String getJobHandlerConfiguration()
public void setJobHandlerConfiguration(String jobHandlerConfiguration)
public int getRevision()
getRevision in interface HasRevisionpublic void setRevision(int revision)
setRevision in interface HasRevisionpublic String getExceptionMessage()
JobManagementService.getJobExceptionStacktrace(String)getExceptionMessage in interface Jobpublic void setExceptionMessage(String exceptionMessage)
public String getExceptionByteArrayId()
public String getDeploymentId()
JobgetDeploymentId in interface Jobpublic void setDeploymentId(String deploymentId)
Copyright © 2015. All rights reserved.