Modifier and Type | Method and Description |
---|---|
void |
BackoffStrategy.reconfigure(List<ExternalTask> externalTasks)
Reconfigures the back off strategy based on the fetched external tasks and is invoked
before
BackoffStrategy.calculateBackoffTime() . |
void |
ExponentialBackoffStrategy.reconfigure(List<ExternalTask> externalTasks) |
Modifier and Type | Method and Description |
---|---|
List<ExternalTask> |
EngineClient.fetchAndLock(List<TopicRequestDto> topics) |
Modifier and Type | Method and Description |
---|---|
void |
ExternalTaskService.complete(ExternalTask externalTask)
Completes a task.
|
void |
ExternalTaskService.complete(ExternalTask externalTask,
Map<String,Object> variables)
Completes a task.
|
void |
ExternalTaskService.complete(ExternalTask externalTask,
Map<String,Object> variables,
Map<String,Object> localVariables)
Completes a task.
|
void |
ExternalTaskHandler.execute(ExternalTask externalTask,
ExternalTaskService externalTaskService)
Has been executed for each fetched and locked task
|
void |
ExternalTaskService.extendLock(ExternalTask externalTask,
long newDuration)
Extends the timeout of the lock by a given amount of time.
|
void |
ExternalTaskService.handleBpmnError(ExternalTask externalTask,
String errorCode)
Reports a business error in the context of a running task.
|
void |
ExternalTaskService.handleBpmnError(ExternalTask externalTask,
String errorCode,
String errorMessage)
Reports a business error in the context of a running task.
|
void |
ExternalTaskService.handleBpmnError(ExternalTask externalTask,
String errorCode,
String errorMessage,
Map<String,Object> variables)
Reports a business error in the context of a running task.
|
void |
ExternalTaskService.handleFailure(ExternalTask externalTask,
String errorMessage,
String errorDetails,
int retries,
long retryTimeout)
Reports a failure to execute a task.
|
void |
ExternalTaskService.lock(ExternalTask externalTask,
long lockDuration)
Locks a task by a given amount of time.
|
void |
ExternalTaskService.unlock(ExternalTask externalTask)
Unlocks a task and clears the tasks lock expiration time and worker id.
|
Modifier and Type | Class and Description |
---|---|
class |
ExternalTaskImpl |
Modifier and Type | Method and Description |
---|---|
void |
ExternalTaskServiceImpl.complete(ExternalTask externalTask) |
void |
ExternalTaskServiceImpl.complete(ExternalTask externalTask,
Map<String,Object> variables) |
void |
ExternalTaskServiceImpl.complete(ExternalTask externalTask,
Map<String,Object> variables,
Map<String,Object> localVariables) |
void |
ExternalTaskServiceImpl.extendLock(ExternalTask externalTask,
long newDuration) |
void |
ExternalTaskServiceImpl.handleBpmnError(ExternalTask externalTask,
String errorCode) |
void |
ExternalTaskServiceImpl.handleBpmnError(ExternalTask externalTask,
String errorCode,
String errorMessage) |
void |
ExternalTaskServiceImpl.handleBpmnError(ExternalTask externalTask,
String errorCode,
String errorMessage,
Map<String,Object> variables) |
void |
ExternalTaskServiceImpl.handleFailure(ExternalTask externalTask,
String errorMessage,
String errorDetails,
int retries,
long retryTimeout) |
void |
ExternalTaskServiceImpl.lock(ExternalTask externalTask,
long lockDuration) |
void |
ExternalTaskServiceImpl.unlock(ExternalTask externalTask) |
Modifier and Type | Method and Description |
---|---|
protected List<ExternalTask> |
TopicSubscriptionManager.fetchAndLock(List<TopicRequestDto> subscriptions) |
Modifier and Type | Method and Description |
---|---|
protected void |
TopicSubscriptionManager.handleExternalTask(ExternalTask externalTask,
ExternalTaskHandler taskHandler) |
Modifier and Type | Method and Description |
---|---|
protected void |
TopicSubscriptionManager.runBackoffStrategy(List<ExternalTask> externalTasks) |
Modifier and Type | Method and Description |
---|---|
Map<String,VariableValue> |
TypedValues.wrapVariables(ExternalTask externalTask,
Map<String,TypedValueField> variables) |
Copyright © 2022. All rights reserved.