| Modifier and Type | Class and Description |
|---|---|
class |
AbstractJobEntity
Abstract job entity class.
|
class |
DeadLetterJobEntity |
class |
JobEntity
Job entity for persisting executable jobs.
|
class |
SuspendedJobEntity |
class |
TimerJobEntity |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
Flowable5Util.isJobHandledByV5Engine(JobInfo jobInfo) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
AcquiredExternalWorkerJob |
interface |
ExternalWorkerJob |
interface |
HistoryJob
Represents one history job
|
interface |
Job
Represents one job (timer, async job, etc.).
|
| Modifier and Type | Class and Description |
|---|---|
class |
AcquiredExternalWorkerJobImpl |
| Modifier and Type | Field and Description |
|---|---|
protected JobInfo |
ExecuteAsyncRunnable.job |
protected JobInfo |
JobAddedTransactionListener.job |
| Modifier and Type | Field and Description |
|---|---|
protected LinkedList<JobInfo> |
AbstractAsyncExecutor.temporaryJobQueue |
| Modifier and Type | Method and Description |
|---|---|
Runnable |
ExecuteAsyncRunnableFactory.createExecuteAsyncRunnable(JobInfo job,
JobServiceConfiguration jobServiceConfiguration) |
protected Runnable |
AbstractAsyncExecutor.createRunnableForJob(JobInfo job) |
void |
DefaultJobManager.execute(JobInfo job) |
void |
JobManager.execute(JobInfo job)
Execute a job, which means that the logic (async logic, timer that fires, etc) is executed, typically by a background thread of an executor.
|
boolean |
AbstractAsyncExecutor.executeAsyncJob(JobInfo job) |
boolean |
AsyncExecutor.executeAsyncJob(JobInfo job)
Offers the provided
JobInfo to this AsyncExecutor instance to execute. |
protected abstract boolean |
AbstractAsyncExecutor.executeAsyncJob(JobInfo job,
Runnable runnable) |
protected boolean |
DefaultAsyncJobExecutor.executeAsyncJob(JobInfo job,
Runnable runnable) |
boolean |
UnacquireAsyncHistoryJobExceptionHandler.handleException(JobServiceConfiguration jobServiceConfiguration,
JobInfo job,
Throwable exception) |
boolean |
DefaultDebuggerExecutionExceptionHandler.handleException(JobServiceConfiguration jobServiceConfiguration,
JobInfo job,
Throwable exception) |
boolean |
DefaultAsyncRunnableExecutionExceptionHandler.handleException(JobServiceConfiguration jobServiceConfiguration,
JobInfo job,
Throwable exception) |
boolean |
AsyncRunnableExecutionExceptionHandler.handleException(JobServiceConfiguration jobServiceConfiguration,
JobInfo job,
Throwable exception) |
protected void |
DefaultJobManager.sendMoveToDeadletterEvent(JobInfo job) |
protected void |
DefaultAsyncJobExecutor.sendRejectedEvent(JobInfo job) |
void |
DefaultJobManager.unacquire(JobInfo job) |
void |
JobManager.unacquire(JobInfo job)
Unacquires a job, meaning that this job was previously locked, and it is now freed to be acquired by other executor nodes.
|
protected void |
DefaultAsyncJobExecutor.unacquireJobAfterRejection(JobInfo job) |
void |
DefaultJobManager.unacquireWithDecrementRetries(JobInfo job,
Throwable exception) |
void |
JobManager.unacquireWithDecrementRetries(JobInfo job,
Throwable exception)
Unacquires a job, meaning that this job was previously locked, and it is now freed to be acquired by other executor nodes.
|
| Constructor and Description |
|---|
ExecuteAsyncRunnable(JobInfo job,
JobServiceConfiguration jobServiceConfiguration,
JobInfoEntityManager<? extends JobInfoEntity> jobEntityManager,
AsyncRunnableExecutionExceptionHandler asyncRunnableExecutionExceptionHandler) |
JobAddedTransactionListener(JobInfo job,
AsyncExecutor asyncExecutor,
CommandExecutor commandExecutor) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
AbstractMessageBasedJobManager.prepareAndSendMessage(JobInfo job) |
protected abstract void |
AbstractMessageBasedJobManager.sendMessage(JobInfo job)
Subclasses need to implement this method: it should contain the actual sending of the message
using the job data provided in the parameter.
|
void |
AbstractMessageBasedJobManager.unacquire(JobInfo job) |
void |
AbstractMessageBasedJobManager.unacquireWithDecrementRetries(JobInfo job,
Throwable throwable) |
| Modifier and Type | Method and Description |
|---|---|
Runnable |
TenantAwareExecuteAsyncRunnableFactory.createExecuteAsyncRunnable(JobInfo job,
JobServiceConfiguration jobServiceConfiguration) |
boolean |
ExecutorPerTenantAsyncExecutor.executeAsyncJob(JobInfo job) |
| Constructor and Description |
|---|
TenantAwareExecuteAsyncRunnable(JobInfo job,
JobServiceConfiguration jobServiceConfiguration,
TenantInfoHolder tenantInfoHolder,
String tenantId) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
AbstractRuntimeJobEntity |
interface |
DeadLetterJobEntity
Suspended jobs are stored separately to increase the normal job query performance
|
interface |
ExternalWorkerJobEntity
Represents an external job.
|
interface |
HistoryJobEntity |
interface |
JobEntity
Represents an async job: a piece of logic that needs to be executed asynchronously.
|
interface |
JobInfoEntity |
interface |
SuspendedJobEntity
Suspended jobs are stored separately to increase the normal job query performance
|
interface |
TimerJobEntity
Stub of the common parts of a timer job.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractJobEntityImpl
Abstract job entity class.
|
class |
DeadLetterJobEntityImpl
DeadLetterJob entity, necessary for persistence.
|
class |
ExternalWorkerJobEntityImpl |
class |
HistoryJobEntityImpl
History Job entity.
|
class |
JobEntityImpl
Job entity.
|
class |
SuspendedJobEntityImpl
TimerJob entity, necessary for persistence.
|
class |
TimerJobEntityImpl
TimerJob entity, necessary for persistence.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
MessageBasedJobManager.sendMessage(JobInfo job) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
SpringAsyncExecutor.executeAsyncJob(JobInfo job) |
void |
SpringCallerRunsRejectedJobsHandler.jobRejected(AsyncExecutor asyncExecutor,
JobInfo job) |
void |
SpringRejectedJobsHandler.jobRejected(AsyncExecutor asyncExecutor,
JobInfo job) |
Copyright © 2023 Flowable. All rights reserved.