org.flowable.cmmn.engine.impl.behavior.impl.http

Class DefaultCmmnHttpActivityDelegate

java.lang.Object

org.flowable.http.common.impl.BaseHttpActivityDelegate

org.flowable.cmmn.engine.impl.behavior.impl.http.DefaultCmmnHttpActivityDelegate

All Implemented Interfaces:

PlanItemFutureJavaDelegate<BaseHttpActivityDelegate.ExecutionData>

public class DefaultCmmnHttpActivityDelegate
extends BaseHttpActivityDelegate
implements PlanItemFutureJavaDelegate<BaseHttpActivityDelegate.ExecutionData>

Author:

Filip Hrisafov

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 and Description
DefaultCmmnHttpActivityDelegate()
DefaultCmmnHttpActivityDelegate(FlowableHttpClient httpClient)

Method Summary

Modifier and Type	Method and Description
void	afterExecution(DelegatePlanItemInstance planItemInstance, BaseHttpActivityDelegate.ExecutionData result) Method invoked with the result from PlanItemFutureJavaDelegate.execute(DelegatePlanItemInstance, AsyncTaskInvoker).
protected FlowableHttpClient	createHttpClient()
protected HttpRequestHandler	createHttpRequestHandler(FlowableHttpRequestHandler handler, CmmnEngineConfiguration cmmnEngineConfiguration)
protected HttpResponseHandler	createHttpResponseHandler(FlowableHttpResponseHandler handler, CmmnEngineConfiguration cmmnEngineConfiguration)
CompletableFuture<BaseHttpActivityDelegate.ExecutionData>	execute(DelegatePlanItemInstance planItemInstance, 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

DefaultCmmnHttpActivityDelegate

public DefaultCmmnHttpActivityDelegate()

DefaultCmmnHttpActivityDelegate

public DefaultCmmnHttpActivityDelegate(FlowableHttpClient httpClient)

Method Detail

createHttpClient

protected FlowableHttpClient createHttpClient()

Specified by:

createHttpClient in class BaseHttpActivityDelegate

execute

public CompletableFuture<BaseHttpActivityDelegate.ExecutionData> execute(DelegatePlanItemInstance planItemInstance,
                                                                         AsyncTaskInvoker taskInvoker)

Description copied from interface: PlanItemFutureJavaDelegate

Perform the execution of the delegate, potentially on another thread. The result of the future is passed in the PlanItemFutureJavaDelegate.afterExecution(DelegatePlanItemInstance, Object) in order to store the data on the planItemInstance on the same thread as the caller of this method. IMPORTANT: the planItemInstance should only be used to read data before creating the future. The planItemInstance 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 PlanItemFutureJavaDelegate<BaseHttpActivityDelegate.ExecutionData>

Parameters:

planItemInstance - the planItemInstance 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(DelegatePlanItemInstance planItemInstance,
                           BaseHttpActivityDelegate.ExecutionData result)

Description copied from interface: PlanItemFutureJavaDelegate

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

Specified by:

afterExecution in interface PlanItemFutureJavaDelegate<BaseHttpActivityDelegate.ExecutionData>

Parameters:

planItemInstance - the planItemInstance to which data can be set

result - the execution data

createHttpRequestHandler

protected HttpRequestHandler createHttpRequestHandler(FlowableHttpRequestHandler handler,
                                                      CmmnEngineConfiguration cmmnEngineConfiguration)

createHttpResponseHandler

protected HttpResponseHandler createHttpResponseHandler(FlowableHttpResponseHandler handler,
                                                        CmmnEngineConfiguration cmmnEngineConfiguration)

propagateError

protected void propagateError(VariableContainer container,
                              String code)

Specified by:

propagateError in class BaseHttpActivityDelegate