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

Class A2AAgentPollJobHandler

java.lang.Object

com.flowable.agent.engine.impl.job.A2AAgentPollJobHandler

All Implemented Interfaces:

org.flowable.job.service.JobHandler

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final record	A2AAgentPollJobHandler.RetryConfiguration

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TYPE

Constructor Summary

Constructors

Constructor	Description
A2AAgentPollJobHandler()

Method Summary

Modifier and Type	Method	Description
protected Date	calculateDueDate(org.flowable.common.engine.impl.runtime.Clock clock, int currentRetryCount, Date oldDate, Duration retryTimeout)
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 A2AAgentPollJobHandler.RetryConfiguration	getRetryConfiguration(AgentDefinitionModel agentDefinitionModel)
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, Duration retryTimeout)

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

Constructor Details

A2AAgentPollJobHandler

public A2AAgentPollJobHandler()

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

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,
 Duration retryTimeout)

calculateDueDate

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

getRetryConfiguration

protected A2AAgentPollJobHandler.RetryConfiguration getRetryConfiguration(AgentDefinitionModel agentDefinitionModel)