Package com.flowable.agent.engine.impl.job

Class ExternalAgentPollJobHandler

java.lang.Object

com.flowable.agent.engine.impl.job.ExternalAgentPollJobHandler

All Implemented Interfaces:

org.flowable.job.service.JobHandler

public class ExternalAgentPollJobHandler
extends Object
implements org.flowable.job.service.JobHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected Duration	retryTimeout
static final String	TYPE

Constructor Summary

Constructors

Constructor	Description
ExternalAgentPollJobHandler()

Method Summary

Modifier and Type	Method	Description
protected void	auditExternalAgentPollInvocation(AgentEngineConfiguration agentEngineConfiguration, AgentInstanceEntity agentInstanceEntity, String agentInvocationId, Date pollStartDate, Date pollEndDate, String externalAgentConfig, String stringResult)
protected Date	calculateDueDate(org.flowable.common.engine.impl.runtime.Clock clock, int currentRetryCount, Date oldDate)
void	execute(org.flowable.job.service.impl.persistence.entity.JobEntity job, String configuration, org.flowable.variable.api.delegate.VariableScope variableScope, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
protected static long	getLongProperty(Map<String,Object> properties, String property, long defaultValue)
protected org.springframework.ai.converter.StructuredOutputConverter<com.fasterxml.jackson.databind.JsonNode>	getOutputConverter(AgentEngineConfiguration agentEngineConfiguration, String outputSchema, AgentDefinitionModel.AgentOperation agentOperation)
String	getType()
protected void	reschedulePollingJob(org.flowable.job.service.impl.persistence.entity.JobEntity job, org.flowable.variable.api.delegate.VariableScope variableScope, org.flowable.common.engine.impl.interceptor.CommandContext commandContext, int currentRetryCount)

Methods inherited from class java.lang.Object

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

Field Details

TYPE

public static final String TYPE

See Also:

• Constant Field Values

retryTimeout

protected Duration retryTimeout

Constructor Details

ExternalAgentPollJobHandler

public ExternalAgentPollJobHandler()

Method Details

getType

public String getType()

Specified by:

getType in interface org.flowable.job.service.JobHandler

execute

public void execute(org.flowable.job.service.impl.persistence.entity.JobEntity job,
 String configuration,
 org.flowable.variable.api.delegate.VariableScope variableScope,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

Specified by:

execute in interface org.flowable.job.service.JobHandler

auditExternalAgentPollInvocation

protected void auditExternalAgentPollInvocation(AgentEngineConfiguration agentEngineConfiguration,
 AgentInstanceEntity agentInstanceEntity,
 String agentInvocationId,
 Date pollStartDate,
 Date pollEndDate,
 String externalAgentConfig,
 String stringResult)

reschedulePollingJob

protected void reschedulePollingJob(org.flowable.job.service.impl.persistence.entity.JobEntity job,
 org.flowable.variable.api.delegate.VariableScope variableScope,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 int currentRetryCount)

calculateDueDate

protected Date calculateDueDate(org.flowable.common.engine.impl.runtime.Clock clock,
 int currentRetryCount,
 Date oldDate)

getOutputConverter

protected org.springframework.ai.converter.StructuredOutputConverter<com.fasterxml.jackson.databind.JsonNode> getOutputConverter(AgentEngineConfiguration agentEngineConfiguration,
 String outputSchema,
 AgentDefinitionModel.AgentOperation agentOperation)

getLongProperty

protected static long getLongProperty(Map<String,Object> properties,
 String property,
 long defaultValue)