Package com.flowable.serviceregistry.engine.impl.cmd

Class InvokeServiceCmd

java.lang.Object

com.flowable.serviceregistry.engine.impl.cmd.InvokeServiceCmd

All Implemented Interfaces:

Command<ServiceInvocationResultResponse>

public class InvokeServiceCmd
extends Object
implements Command<ServiceInvocationResultResponse>

Field Summary

Fields

Modifier and Type	Field	Description
protected ServiceInvocationBuilder	serviceInvocationBuilder

Constructor Summary

Constructors

Constructor	Description
InvokeServiceCmd(ServiceInvocationBuilder serviceInvocationBuilder)

Method Summary

Modifier and Type	Method	Description
protected ServiceInvocationResult	convertToServiceInvocationResult(ServiceInvocationResultResponse invocationResponse, ServiceInvocationResult processedResult)
protected Collection<ServiceInvocationResult>	convertToServiceInvocationResults(ServiceInvocationResultResponse invocationResponse, ServiceInvocationResultResponse result)
protected Map<String,Object>	createValidateAndCompleteServiceInvocationInputDataMap(ServiceDefinition serviceDefinition, ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, com.fasterxml.jackson.databind.ObjectMapper objectMapper, ExpressionManager expressionManager)	Creates, validates and completes the service invocation data according the input parameter definition of the service.
ServiceInvocationResultResponse	execute(CommandContext commandContext)
protected ServiceDefinitionEntity	getServiceDefinition(String tenantId, CommandContext commandContext)
protected ServiceDefinitionModel	getServiceDefinitionModel(ServiceDefinitionEntity serviceDefinition, CommandContext commandContext)
protected ServiceInvoker	getServiceInvoker(ServiceDefinitionModel serviceDefinitionModel, CommandContext commandContext)
protected ServiceOperation	getServiceOperation(ServiceDefinitionModel serviceDefinitionModel)
protected ServiceInvocationResultResponse	handleServiceInvocationResponse(ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, ServiceInvoker serviceInvoker, ServiceInvocationContextImpl context, ServiceRegistryEngineConfiguration serviceEngineConfiguration, ServiceInvocationResultResponse invocationResponse)
protected ServiceInvocationResultResponse	internalInvoke(ServiceInvoker serviceInvoker, ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, ServiceInvocationContextImpl context, CommandContext commandContext)
protected ServiceInvocationResultResponse	invokeService(ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, ServiceInvoker serviceInvoker, ServiceInvocationContextImpl context, CommandContext commandContext)
protected void	processAndValidateInputParameter(ServiceDefinition serviceDefinition, ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, ServiceInputParameter inputParameter, Map<String,Object> serviceInvocationInputData, com.fasterxml.jackson.databind.ObjectMapper objectMapper, ExpressionManager expressionManager)	Internal method to process a single input parameter by looking at its definition and checking its value.
protected ServiceDefinitionEntity	resolveServiceDefinitionByKey(String tenantId, ServiceRegistryEngineConfiguration serviceEngineConfiguration)
protected ServiceDefinitionEntity	resolveServiceDefinitionByReferenceKey(String tenantId, ServiceDefinitionEntityManager serviceDefinitionEntityManager, CommandContext commandContext)
protected void	validateOperationTypeMatchesRequestedType(ServiceOperation operation, String requestedOperationType)
protected void	validateParameters()

Methods inherited from class java.lang.Object

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

Field Details

serviceInvocationBuilder

protected ServiceInvocationBuilder serviceInvocationBuilder

Constructor Details

InvokeServiceCmd

public InvokeServiceCmd(ServiceInvocationBuilder serviceInvocationBuilder)

Method Details

execute

public ServiceInvocationResultResponse execute(CommandContext commandContext)

Specified by:

execute in interface Command<ServiceInvocationResultResponse>

validateParameters

protected void validateParameters()

createValidateAndCompleteServiceInvocationInputDataMap

protected Map<String,Object> createValidateAndCompleteServiceInvocationInputDataMap(ServiceDefinition serviceDefinition,
 ServiceDefinitionModel serviceDefinitionModel,
 ServiceOperation serviceOperation,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 ExpressionManager expressionManager)

Creates, validates and completes the service invocation data according the input parameter definition of the service.

Parameters:

serviceDefinition -

serviceDefinitionModel - the service definition model the invocation is based on

serviceOperation - the service operation representing the service to be invoked

objectMapper - the object mapper used for creating and initializing variable values in JSON

expressionManager - the expression manager used for evaluating default values for input parameters

Returns:

the initialized and validated variable data map

Throws:

FlowableIllegalArgumentException - if the input parameter validation failed (e.g. a required parameter value was missing)

processAndValidateInputParameter

protected void processAndValidateInputParameter(ServiceDefinition serviceDefinition,
 ServiceDefinitionModel serviceDefinitionModel,
 ServiceOperation serviceOperation,
 ServiceInputParameter inputParameter,
 Map<String,Object> serviceInvocationInputData,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 ExpressionManager expressionManager)

Internal method to process a single input parameter by looking at its definition and checking its value. If a required input parameters value is missing and no default one is provided, it will throw an exception.

Parameters:

serviceDefinition - the service definition

serviceDefinitionModel - the service definition model the invocation is based on

serviceOperation - the service operation the invocation is based on

inputParameter - the input parameter to be processed

serviceInvocationInputData - the service invocation input data map to be validated and completed for the given parameter

objectMapper - the object mapper used for creating and initializing variable values in JSON

expressionManager - the expression manager used for evaluating default values for input parameters

Throws:

FlowableIllegalArgumentException - if the input parameter validation failed (e.g. a required parameter value was missing)

getServiceDefinition

protected ServiceDefinitionEntity getServiceDefinition(String tenantId,
 CommandContext commandContext)

resolveServiceDefinitionByKey

protected ServiceDefinitionEntity resolveServiceDefinitionByKey(String tenantId,
 ServiceRegistryEngineConfiguration serviceEngineConfiguration)

resolveServiceDefinitionByReferenceKey

protected ServiceDefinitionEntity resolveServiceDefinitionByReferenceKey(String tenantId,
 ServiceDefinitionEntityManager serviceDefinitionEntityManager,
 CommandContext commandContext)

getServiceDefinitionModel

protected ServiceDefinitionModel getServiceDefinitionModel(ServiceDefinitionEntity serviceDefinition,
 CommandContext commandContext)

getServiceInvoker

protected ServiceInvoker getServiceInvoker(ServiceDefinitionModel serviceDefinitionModel,
 CommandContext commandContext)

getServiceOperation

protected ServiceOperation getServiceOperation(ServiceDefinitionModel serviceDefinitionModel)

validateOperationTypeMatchesRequestedType

protected void validateOperationTypeMatchesRequestedType(ServiceOperation operation,
 String requestedOperationType)

invokeService

protected ServiceInvocationResultResponse invokeService(ServiceDefinitionModel serviceDefinitionModel,
 ServiceOperation serviceOperation,
 ServiceInvoker serviceInvoker,
 ServiceInvocationContextImpl context,
 CommandContext commandContext)

internalInvoke

protected ServiceInvocationResultResponse internalInvoke(ServiceInvoker serviceInvoker,
 ServiceDefinitionModel serviceDefinitionModel,
 ServiceOperation serviceOperation,
 ServiceInvocationContextImpl context,
 CommandContext commandContext)

handleServiceInvocationResponse

protected ServiceInvocationResultResponse handleServiceInvocationResponse(ServiceDefinitionModel serviceDefinitionModel,
 ServiceOperation serviceOperation,
 ServiceInvoker serviceInvoker,
 ServiceInvocationContextImpl context,
 ServiceRegistryEngineConfiguration serviceEngineConfiguration,
 ServiceInvocationResultResponse invocationResponse)

convertToServiceInvocationResults

protected Collection<ServiceInvocationResult> convertToServiceInvocationResults(ServiceInvocationResultResponse invocationResponse,
 ServiceInvocationResultResponse result)

convertToServiceInvocationResult

protected ServiceInvocationResult convertToServiceInvocationResult(ServiceInvocationResultResponse invocationResponse,
 ServiceInvocationResult processedResult)