Package org.finos.fluxnova.bpm.client.impl

Class EngineClient

java.lang.Object

org.finos.fluxnova.bpm.client.impl.EngineClient

public class EngineClient
extends Object

Author:

Tassilo Weidner

Field Summary

Fields

Modifier and Type	Field	Description
protected Long	asyncResponseTimeout
static final String	BPMN_ERROR_RESOURCE_PATH
static final String	COMPLETE_RESOURCE_PATH
protected RequestExecutor	engineInteraction
static final String	EXTEND_LOCK_RESOURCE_PATH
protected static final String	EXTERNAL_TASK__PROCESS_RESOURCE_PATH
protected static final String	EXTERNAL_TASK_RESOURCE_PATH
static final String	FAILURE_RESOURCE_PATH
protected static final String	FETCH_AND_LOCK_RESOURCE_PATH
static final String	GET_BINARY_VARIABLE
static final String	ID_PATH_PARAM
protected static final String	ID_RESOURCE_PATH
static final String	LOCK_RESOURCE_PATH
protected int	maxTasks
static final String	NAME_PATH_PARAM
protected OrderingConfig	orderingConfig
static final String	PROCESS_INSTANCE_ID_RESOURCE_PATH
static final String	PROCESS_INSTANCE_RESOURCE_PATH
static final String	SET_VARIABLES_RESOURCE_PATH
protected TypedValues	typedValues
static final String	UNLOCK_RESOURCE_PATH
protected UrlResolver	urlResolver
protected boolean	usePriority
protected String	workerId

Constructor Summary

Constructors

Constructor	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, OrderingConfig orderingConfig)
EngineClient(String workerId, int maxTasks, Long asyncResponseTimeout, UrlResolver urlResolver, RequestExecutor engineInteraction)
EngineClient(String workerId, int maxTasks, Long asyncResponseTimeout, UrlResolver urlResolver, RequestExecutor engineInteraction, boolean usePriority, OrderingConfig orderingConfig)

Method Summary

Modifier and Type	Method	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 executionId)
String	getWorkerId()
boolean	isUsePriority()
void	lock(String taskId, long lockDuration)
void	setTypedValues(TypedValues typedValues)
void	setVariables(String processId, Map<String,Object> variables)
void	unlock(String taskId)

Methods inherited from class java.lang.Object

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

Field Details

EXTERNAL_TASK_RESOURCE_PATH

protected static final String EXTERNAL_TASK_RESOURCE_PATH

See Also:

• Constant Field Values

EXTERNAL_TASK__PROCESS_RESOURCE_PATH

protected static final String EXTERNAL_TASK__PROCESS_RESOURCE_PATH

See Also:

• Constant Field Values

FETCH_AND_LOCK_RESOURCE_PATH

protected static final String FETCH_AND_LOCK_RESOURCE_PATH

See Also:

• Constant Field Values

ID_PATH_PARAM

public static final String ID_PATH_PARAM

See Also:

• Constant Field Values

ID_RESOURCE_PATH

protected static final String ID_RESOURCE_PATH

See Also:

• Constant Field Values

LOCK_RESOURCE_PATH

public static final String LOCK_RESOURCE_PATH

See Also:

• Constant Field Values

EXTEND_LOCK_RESOURCE_PATH

public static final String EXTEND_LOCK_RESOURCE_PATH

See Also:

• Constant Field Values

SET_VARIABLES_RESOURCE_PATH

public static final String SET_VARIABLES_RESOURCE_PATH

See Also:

• Constant Field Values

UNLOCK_RESOURCE_PATH

public static final String UNLOCK_RESOURCE_PATH

See Also:

• Constant Field Values

COMPLETE_RESOURCE_PATH

public static final String COMPLETE_RESOURCE_PATH

See Also:

• Constant Field Values

FAILURE_RESOURCE_PATH

public static final String FAILURE_RESOURCE_PATH

See Also:

• Constant Field Values

BPMN_ERROR_RESOURCE_PATH

public static final String BPMN_ERROR_RESOURCE_PATH

See Also:

• Constant Field Values

NAME_PATH_PARAM

public static final String NAME_PATH_PARAM

See Also:

• Constant Field Values

PROCESS_INSTANCE_RESOURCE_PATH

public static final String PROCESS_INSTANCE_RESOURCE_PATH

See Also:

• Constant Field Values

PROCESS_INSTANCE_ID_RESOURCE_PATH

public static final String PROCESS_INSTANCE_ID_RESOURCE_PATH

See Also:

• Constant Field Values

GET_BINARY_VARIABLE

public static final String GET_BINARY_VARIABLE

See Also:

• Constant Field Values

urlResolver

protected UrlResolver urlResolver

workerId

protected String workerId

maxTasks

protected int maxTasks

usePriority

protected boolean usePriority

orderingConfig

protected OrderingConfig orderingConfig

asyncResponseTimeout

protected Long asyncResponseTimeout

engineInteraction

protected RequestExecutor engineInteraction

typedValues

protected TypedValues typedValues

Constructor Details

EngineClient

public EngineClient(String workerId,
 int maxTasks,
 Long asyncResponseTimeout,
 String baseUrl,
 RequestExecutor engineInteraction)

EngineClient

public EngineClient(String workerId,
 int maxTasks,
 Long asyncResponseTimeout,
 String baseUrl,
 RequestExecutor engineInteraction,
 boolean usePriority,
 OrderingConfig orderingConfig)

EngineClient

public EngineClient(String workerId,
 int maxTasks,
 Long asyncResponseTimeout,
 UrlResolver urlResolver,
 RequestExecutor engineInteraction)

EngineClient

public EngineClient(String workerId,
 int maxTasks,
 Long asyncResponseTimeout,
 UrlResolver urlResolver,
 RequestExecutor engineInteraction,
 boolean usePriority,
 OrderingConfig orderingConfig)

Method Details

fetchAndLock

public List<ExternalTask> fetchAndLock(List<TopicRequestDto> topics)

lock

public void lock(String taskId,
 long lockDuration)

unlock

public void unlock(String taskId)

complete

public void complete(String taskId,
 Map<String,Object> variables,
 Map<String,Object> localVariables)

setVariables

public void setVariables(String processId,
 Map<String,Object> variables)

failure

public void failure(String taskId,
 String errorMessage,
 String errorDetails,
 int retries,
 long retryTimeout,
 Map<String,Object> variables,
 Map<String,Object> localVariables)

bpmnError

public void bpmnError(String taskId,
 String errorCode,
 String errorMessage,
 Map<String,Object> variables)

extendLock

public void extendLock(String taskId,
 long newDuration)

getLocalBinaryVariable

public byte[] getLocalBinaryVariable(String variableName,
 String executionId)

getBaseUrl

public String getBaseUrl()

getWorkerId

public String getWorkerId()

setTypedValues

public void setTypedValues(TypedValues typedValues)

isUsePriority

public boolean isUsePriority()