Package org.flowable.engine.impl.bpmn.http

Class DefaultBpmnHttpActivityDelegate

java.lang.Object

org.flowable.http.common.impl.BaseHttpActivityDelegate

org.flowable.engine.impl.bpmn.http.DefaultBpmnHttpActivityDelegate

All Implemented Interfaces:

FutureJavaDelegate<BaseHttpActivityDelegate.ExecutionData>

public class DefaultBpmnHttpActivityDelegate
extends BaseHttpActivityDelegate
implements FutureJavaDelegate<BaseHttpActivityDelegate.ExecutionData>

Author:

Filip Hrisafov, Joram Barrez

Nested Class Summary

Nested classes/interfaces inherited from class org.flowable.http.common.impl.BaseHttpActivityDelegate

BaseHttpActivityDelegate.ExecutionData

Field Summary

Fields inherited from class org.flowable.http.common.impl.BaseHttpActivityDelegate

disallowRedirects, failStatusCodes, handleStatusCodes, HTTP_TASK_REQUEST_FIELD_INVALID, HTTP_TASK_REQUEST_HEADERS_INVALID, HTTP_TASK_REQUEST_METHOD_INVALID, HTTP_TASK_REQUEST_METHOD_REQUIRED, HTTP_TASK_REQUEST_URL_REQUIRED, httpClient, ignoreException, requestBody, requestBodyEncoding, requestHeaders, requestMethod, requestTimeout, requestUrl, responseVariableName, resultVariablePrefix, saveRequestVariables, saveResponseParameters, saveResponseParametersTransient, saveResponseVariableAsJson

Constructor Summary

Constructors

Constructor	Description
DefaultBpmnHttpActivityDelegate()
DefaultBpmnHttpActivityDelegate(FlowableHttpClient httpClient)

Method Summary

Modifier and Type	Method	Description
void	afterExecution(DelegateExecution execution, BaseHttpActivityDelegate.ExecutionData result)	Method invoked with the result from FutureJavaDelegate.execute(DelegateExecution, AsyncTaskInvoker).
protected Expression	createExpression(ExpressionManager expManager, Object value)
protected List<FieldDeclaration>	createFieldDeclarations(List<org.flowable.bpmn.model.FieldExtension> fieldList, ProcessEngineConfigurationImpl processEngineConfiguration)
protected FlowableHttpClient	createHttpClient()
protected HttpRequestHandler	createHttpRequestHandler(org.flowable.bpmn.model.FlowableHttpRequestHandler handler, ProcessEngineConfigurationImpl processEngineConfiguration)
protected HttpResponseHandler	createHttpResponseHandler(org.flowable.bpmn.model.FlowableHttpResponseHandler handler, ProcessEngineConfigurationImpl processEngineConfiguration)
protected ScriptHttpHandler	createScriptHttpHandler(ExpressionManager expressionManager, org.flowable.bpmn.model.ScriptInfo scriptInfo)
CompletableFuture<BaseHttpActivityDelegate.ExecutionData>	execute(DelegateExecution execution, AsyncTaskInvoker taskInvoker)	Perform the execution of the delegate, potentially on another thread.
protected void	propagateError(VariableContainer container, String code)

Methods inherited from class org.flowable.http.common.impl.BaseHttpActivityDelegate

createRequest, getRequestHeaders, prepareAndExecuteRequest, saveResponseFields, validateRequest

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBpmnHttpActivityDelegate

public DefaultBpmnHttpActivityDelegate()

DefaultBpmnHttpActivityDelegate

public DefaultBpmnHttpActivityDelegate(FlowableHttpClient httpClient)

Method Detail

createHttpClient

protected FlowableHttpClient createHttpClient()

Specified by:

createHttpClient in class BaseHttpActivityDelegate

execute

public CompletableFuture<BaseHttpActivityDelegate.ExecutionData> execute(DelegateExecution execution,
                                                                         AsyncTaskInvoker taskInvoker)

Description copied from interface: FutureJavaDelegate

Perform the execution of the delegate, potentially on another thread. The result of the future is passed in the FutureJavaDelegate.afterExecution(DelegateExecution, Object) in order to store the data on the execution on the same thread as the caller of this method. IMPORTANT: the execution should only be used to read data before creating the future. The execution should not be used in the task that will be executed on a new thread.

The AsyncTaskInvoker is in order to schedule an execution on a different thread. However, it is also possible to use a different scheduler, or return a future not created by the given taskInvoker.

Specified by:

execute in interface FutureJavaDelegate<BaseHttpActivityDelegate.ExecutionData>

Parameters:

execution - the execution that can be used to extract data

taskInvoker - the task invoker that can be used to execute expensive operation on another thread

Returns:

the output data of the execution

afterExecution

public void afterExecution(DelegateExecution execution,
                           BaseHttpActivityDelegate.ExecutionData result)

Description copied from interface: FutureJavaDelegate

Method invoked with the result from FutureJavaDelegate.execute(DelegateExecution, AsyncTaskInvoker). This should be used to set data on the DelegateExecution. This is on the same thread as FutureJavaDelegate.execute(DelegateExecution, AsyncTaskInvoker) and participates in the process transaction.

Specified by:

afterExecution in interface FutureJavaDelegate<BaseHttpActivityDelegate.ExecutionData>

Parameters:

execution - the execution to which data can be set

result - the execution data

createHttpRequestHandler

protected HttpRequestHandler createHttpRequestHandler(org.flowable.bpmn.model.FlowableHttpRequestHandler handler,
                                                      ProcessEngineConfigurationImpl processEngineConfiguration)

createExpression

protected Expression createExpression(ExpressionManager expManager,
                                      Object value)

createHttpResponseHandler

protected HttpResponseHandler createHttpResponseHandler(org.flowable.bpmn.model.FlowableHttpResponseHandler handler,
                                                        ProcessEngineConfigurationImpl processEngineConfiguration)

createScriptHttpHandler

protected ScriptHttpHandler createScriptHttpHandler(ExpressionManager expressionManager,
                                                    org.flowable.bpmn.model.ScriptInfo scriptInfo)

createFieldDeclarations

protected List<FieldDeclaration> createFieldDeclarations(List<org.flowable.bpmn.model.FieldExtension> fieldList,
                                                         ProcessEngineConfigurationImpl processEngineConfiguration)

propagateError

protected void propagateError(VariableContainer container,
                              String code)

Specified by:

propagateError in class BaseHttpActivityDelegate