Package org.flowable.external.client.impl

Class RestExternalWorkerJobAcquireBuilder

java.lang.Object

org.flowable.external.client.impl.BaseExternalWorkerJobAcquireBuilder

org.flowable.external.client.impl.RestExternalWorkerJobAcquireBuilder

All Implemented Interfaces:

ExternalWorkerJobAcquireBuilder

public class RestExternalWorkerJobAcquireBuilder
extends BaseExternalWorkerJobAcquireBuilder

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.slf4j.Logger	logger
protected final com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected final RestInvoker	restInvoker
protected final String	workerId

Fields inherited from class org.flowable.external.client.impl.BaseExternalWorkerJobAcquireBuilder

lockDuration, numberOfRetries, numberOfTasks, scopeType, topic

Constructor Summary

Constructors

Constructor	Description
RestExternalWorkerJobAcquireBuilder(String workerId, RestInvoker restInvoker, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
protected List<AcquiredExternalWorkerJob>	acquireAndLockInternal()
protected Instant	asInstant(String value)
protected AcquiredExternalWorkerJob	asJob(com.fasterxml.jackson.databind.node.ObjectNode jobNode)
protected List<AcquiredExternalWorkerJob>	asList(String response)
protected void	parseVariables(com.fasterxml.jackson.databind.node.ArrayNode variablesNode, BiConsumer<String,Object> variableConsumer)
protected Object	parseVariableValue(String type, com.fasterxml.jackson.databind.JsonNode valueNode)
protected com.fasterxml.jackson.databind.node.ObjectNode	prepareRequest()
protected List<AcquiredExternalWorkerJob>	sendRequestAndAcquire(com.fasterxml.jackson.databind.node.ObjectNode requestBody)

Methods inherited from class org.flowable.external.client.impl.BaseExternalWorkerJobAcquireBuilder

acquireAndLock, lockDuration, numberOfRetries, numberOfTasks, onlyBpmn, onlyCmmn, scopeType, topic

Methods inherited from class java.lang.Object

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

Field Details

logger

protected final org.slf4j.Logger logger

workerId

protected final String workerId

restInvoker

protected final RestInvoker restInvoker

objectMapper

protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Details

RestExternalWorkerJobAcquireBuilder

public RestExternalWorkerJobAcquireBuilder(String workerId,
 RestInvoker restInvoker,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Details

acquireAndLockInternal

protected List<AcquiredExternalWorkerJob> acquireAndLockInternal()

Specified by:

acquireAndLockInternal in class BaseExternalWorkerJobAcquireBuilder

prepareRequest

protected com.fasterxml.jackson.databind.node.ObjectNode prepareRequest()

sendRequestAndAcquire

protected List<AcquiredExternalWorkerJob> sendRequestAndAcquire(com.fasterxml.jackson.databind.node.ObjectNode requestBody)

asList

protected List<AcquiredExternalWorkerJob> asList(String response)

asJob

protected AcquiredExternalWorkerJob asJob(com.fasterxml.jackson.databind.node.ObjectNode jobNode)

asInstant

protected Instant asInstant(String value)

parseVariables

protected void parseVariables(com.fasterxml.jackson.databind.node.ArrayNode variablesNode,
 BiConsumer<String,Object> variableConsumer)

parseVariableValue

protected Object parseVariableValue(String type,
 com.fasterxml.jackson.databind.JsonNode valueNode)