public class EngineClient extends Object
Modifier and Type | Field and Description |
---|---|
protected Long |
asyncResponseTimeout |
protected String |
baseUrl |
static String |
BPMN_ERROR_RESOURCE_PATH |
static String |
COMPLETE_RESOURCE_PATH |
protected RequestExecutor |
engineInteraction |
static String |
EXECUTION_ID_RESOURCE_PATH |
static String |
EXECUTION_RESOURCE_PATH |
static String |
EXTEND_LOCK_RESOURCE_PATH |
protected static String |
EXTERNAL_TASK_RESOURCE_PATH |
static String |
FAILURE_RESOURCE_PATH |
protected static String |
FETCH_AND_LOCK_RESOURCE_PATH |
static String |
GET_LOCAL_BINARY_VARIABLE |
static String |
GET_LOCAL_VARIABLE |
static String |
ID_PATH_PARAM |
protected static String |
ID_RESOURCE_PATH |
static String |
LOCK_RESOURCE_PATH |
protected int |
maxTasks |
static String |
NAME_PATH_PARAM |
protected TypedValues |
typedValues |
static String |
UNLOCK_RESOURCE_PATH |
protected boolean |
usePriority |
protected String |
workerId |
Constructor and Description |
---|
EngineClient(String workerId,
int maxTasks,
Long asyncResponseTimeout,
String baseUrl,
RequestExecutor engineInteraction) |
EngineClient(String workerId,
int maxTasks,
Long asyncResponseTimeout,
String baseUrl,
RequestExecutor engineInteraction,
boolean usePriority) |
Modifier and Type | Method and Description |
---|---|
void |
bpmnError(String taskId,
String errorCode,
String errorMessage,
Map<String,Object> variables) |
void |
complete(String taskId,
Map<String,Object> variables,
Map<String,Object> localVariables) |
void |
extendLock(String taskId,
long newDuration) |
void |
failure(String taskId,
String errorMessage,
String errorDetails,
int retries,
long retryTimeout,
Map<String,Object> variables,
Map<String,Object> localVariables) |
List<ExternalTask> |
fetchAndLock(List<TopicRequestDto> topics) |
String |
getBaseUrl() |
byte[] |
getLocalBinaryVariable(String variableName,
String processInstanceId) |
String |
getWorkerId() |
boolean |
isUsePriority() |
void |
lock(String taskId,
long lockDuration) |
void |
setTypedValues(TypedValues typedValues) |
void |
unlock(String taskId) |
protected static final String EXTERNAL_TASK_RESOURCE_PATH
protected static final String FETCH_AND_LOCK_RESOURCE_PATH
public static final String ID_PATH_PARAM
protected static final String ID_RESOURCE_PATH
public static final String LOCK_RESOURCE_PATH
public static final String EXTEND_LOCK_RESOURCE_PATH
public static final String UNLOCK_RESOURCE_PATH
public static final String COMPLETE_RESOURCE_PATH
public static final String FAILURE_RESOURCE_PATH
public static final String BPMN_ERROR_RESOURCE_PATH
public static final String NAME_PATH_PARAM
public static final String EXECUTION_RESOURCE_PATH
public static final String EXECUTION_ID_RESOURCE_PATH
public static final String GET_LOCAL_VARIABLE
public static final String GET_LOCAL_BINARY_VARIABLE
protected String baseUrl
protected String workerId
protected int maxTasks
protected boolean usePriority
protected Long asyncResponseTimeout
protected RequestExecutor engineInteraction
protected TypedValues typedValues
public EngineClient(String workerId, int maxTasks, Long asyncResponseTimeout, String baseUrl, RequestExecutor engineInteraction)
public EngineClient(String workerId, int maxTasks, Long asyncResponseTimeout, String baseUrl, RequestExecutor engineInteraction, boolean usePriority)
public List<ExternalTask> fetchAndLock(List<TopicRequestDto> topics) throws EngineClientException
EngineClientException
public void lock(String taskId, long lockDuration) throws EngineClientException
EngineClientException
public void unlock(String taskId) throws EngineClientException
EngineClientException
public void complete(String taskId, Map<String,Object> variables, Map<String,Object> localVariables) throws EngineClientException
EngineClientException
public void failure(String taskId, String errorMessage, String errorDetails, int retries, long retryTimeout, Map<String,Object> variables, Map<String,Object> localVariables) throws EngineClientException
EngineClientException
public void bpmnError(String taskId, String errorCode, String errorMessage, Map<String,Object> variables) throws EngineClientException
EngineClientException
public void extendLock(String taskId, long newDuration) throws EngineClientException
EngineClientException
public byte[] getLocalBinaryVariable(String variableName, String processInstanceId) throws EngineClientException
EngineClientException
public String getBaseUrl()
public String getWorkerId()
public void setTypedValues(TypedValues typedValues)
public boolean isUsePriority()
Copyright © 2022. All rights reserved.