com.centurylink.mdw.microservice

Class OrchestratorActivity

java.lang.Object

com.centurylink.mdw.services.process.BaseActivity

com.centurylink.mdw.workflow.activity.DefaultActivityImpl

com.centurylink.mdw.workflow.activity.AbstractWait

com.centurylink.mdw.workflow.activity.process.InvokeProcessActivityBase

com.centurylink.mdw.microservice.OrchestratorActivity

All Implemented Interfaces:

ActivityCategory, GeneralActivity, InvokeProcessActivity, SuspendableActivity, Category

@Tracked(value=TRACE)
 @Activity(value="Microservice Orchestrator",
          category=InvokeProcessActivity.class,
          icon="com.centurylink.mdw.microservice/orchestrator.png",
          pagelet="com.centurylink.mdw.microservice/orchestrator.pagelet")
public class OrchestratorActivity
extends InvokeProcessActivityBase

Microservice orchestrator adapter activity. ServicePlan, unlike ProcessExecutionPlan, is not updated with instance data. Instead, instance info is saved to the ServiceSummary.

Field Summary

Fields inherited from class com.centurylink.mdw.workflow.activity.process.InvokeProcessActivityBase

SYNCHRONOUS

Fields inherited from class com.centurylink.mdw.services.process.BaseActivity

DISABLED, GROOVY, JAVA_EL, JAVASCRIPT, logger, OUTPUTDOCS

Constructor Summary

Constructors

Constructor and Description
OrchestratorActivity()

Method Summary

Modifier and Type	Method and Description
protected boolean	allSubProcessCompleted()
protected java.util.Map<java.lang.String,java.lang.String>	createBindings(java.util.List<Variable> childVars, int index, com.centurylink.mdw.microservice.Microservice service, boolean passDocumentContent) Returns variable bindings to be passed into subprocess.
protected ProcessInstance	createProcessInstance(int index, com.centurylink.mdw.microservice.Microservice service)
void	execute() This method will be deprecated soon.
protected void	executeServiceSubflowsInParallel(com.centurylink.mdw.microservice.ServicePlan servicePlan)
protected void	executeServiceSubflowsInSequence(com.centurylink.mdw.microservice.ServicePlan servicePlan)
protected int	getDelay()
protected com.centurylink.mdw.microservice.ServicePlan	getServicePlan()
protected java.lang.String	getServicePlanVariableName() You'd need a custom .impl asset to set this through Studio or Hub.
protected ServiceSummary	getServiceSummary(boolean forUpdate)
protected java.lang.String	getServiceSummaryVariableName() You'd need a custom .impl asset to set this through Studio or Hub
protected Process	getSubflow(com.centurylink.mdw.microservice.Microservice service) Can be a process or template.
protected boolean	isParallel()
protected boolean	isSynchronous()
boolean	needSuspend() The method is invoked by the engine right after the activity is executed, to determine whether to put the activity instance in waiting status.
protected boolean	resumeOnProcessFinish(InternalEvent msg, java.lang.Integer status)

Methods inherited from class com.centurylink.mdw.workflow.activity.process.InvokeProcessActivityBase

allowInput, evaluateBindingValue, getOutputParameters, getSubprocess, onFinish, processOtherMessage, resume, resumeOnOtherEvent, resumeWaiting

Methods inherited from class com.centurylink.mdw.workflow.activity.AbstractWait

deregisterEvents, getMessageFromEventMessage, getWaitEventSpecs, handleEventCompletionCode, registerWaitEvents, registerWaitEvents

Methods inherited from class com.centurylink.mdw.workflow.activity.DefaultActivityImpl

execute

Methods inherited from class com.centurylink.mdw.services.process.BaseActivity

createDocument, createDocument, createDocument, createDocument, evaluateExpression, executeScript, getActivityId, getActivityInstance, getActivityInstanceId, getActivityName, getAttribute, getAttribute, getAttribute, getAttribute, getAttributes, getAttributeValue, getAttributeValueSmart, getDocument, getDocumentContent, getDocumentForUpdate, getDocumentType, getEngine, getExternalEventInstanceDetails, getLogger, getMainProcessDefinition, getMasterRequestId, getOutputDocuments, getPackage, getParameterId, getParameters, getParameterStringValue, getParameterType, getParameterValue, getPerformanceLevel, getProcessDefinition, getProcessId, getProcessInstance, getProcessInstanceId, getProcessInstanceOwner, getProcessInstanceOwnerId, getProperty, getRequiredAttribute, getRequiredVariableValue, getReturnCode, getReturnMessage, getRuntimeContext, getScriptEvaluator, getScriptExecClassName, getScriptExecutor, getValue, getValues, getValueSmart, getVariableInstance, getVariableValue, getVariableValueSmart, getWorkTransitionInstanceId, initialize, isDisabled, isLogDebugEnabled, isLogInfoEnabled, isOutputDocument, lockActivityInstance, lockProcessInstance, logdebug, logDebug, logError, logError, logexception, loginfo, logInfo, logsevere, logwarn, logWarn, prepare, setOutputDocuments, setParameterValue, setParameterValueAsDocument, setParameterValues, setProcessInstanceCompletionCode, setReturnCode, setReturnMessage, setValue, setVariableValue, setVariableValue, startTransaction, stopTransaction, translatePlaceHolder, updateDocumentContent, updateDocumentInfo, updateDocumentInfo, valueIsJavaExpression, valueIsVariable

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.centurylink.mdw.activity.types.GeneralActivity

execute

Constructor Detail

OrchestratorActivity

public OrchestratorActivity()

Method Detail

execute

public void execute()
             throws ActivityException

Description copied from class: DefaultActivityImpl

This method will be deprecated soon. The preferred method to override is the execute() that takes an ActivityRuntimeContext and returns Object.

Specified by:

execute in interface GeneralActivity

Overrides:

execute in class DefaultActivityImpl

Throws:

ActivityException

needSuspend

public boolean needSuspend()

Description copied from interface: SuspendableActivity

The method is invoked by the engine right after the activity is executed, to determine whether to put the activity instance in waiting status. Not all suspendible activities need to be suspended. For example, asynchronous process invocation, event wait when the event is already arrived, etc.

Specified by:

needSuspend in interface SuspendableActivity

Overrides:

needSuspend in class AbstractWait

Returns:

true if the activity instance really needs to be suspended (put in WAITING status).

getDelay

protected int getDelay()

isSynchronous

protected boolean isSynchronous()

isParallel

protected boolean isParallel()

getServicePlan

protected com.centurylink.mdw.microservice.ServicePlan getServicePlan()
                                                               throws ActivityException

Throws:

ActivityException

getServicePlanVariableName

protected java.lang.String getServicePlanVariableName()

You'd need a custom .impl asset to set this through Studio or Hub. To view instances in MDWHub you'd also need to customize inspector-tabs.js.

getServiceSummary

protected ServiceSummary getServiceSummary(boolean forUpdate)
                                    throws ActivityException

Throws:

ActivityException

getServiceSummaryVariableName

protected java.lang.String getServiceSummaryVariableName()

You'd need a custom .impl asset to set this through Studio or Hub

getSubflow

protected Process getSubflow(com.centurylink.mdw.microservice.Microservice service)
                      throws ActivityException

Can be a process or template.

Throws:

ActivityException

createProcessInstance

protected ProcessInstance createProcessInstance(int index,
                                                com.centurylink.mdw.microservice.Microservice service)
                                         throws ActivityException,
                                                DataAccessException,
                                                ProcessException,
                                                java.io.IOException

Throws:

ActivityException

DataAccessException

ProcessException

java.io.IOException

createBindings

protected java.util.Map<java.lang.String,java.lang.String> createBindings(java.util.List<Variable> childVars,
                                                                          int index,
                                                                          com.centurylink.mdw.microservice.Microservice service,
                                                                          boolean passDocumentContent)
                                                                   throws ActivityException

Returns variable bindings to be passed into subprocess.

Throws:

ActivityException

resumeOnProcessFinish

protected boolean resumeOnProcessFinish(InternalEvent msg,
                                        java.lang.Integer status)
                                 throws ActivityException

Specified by:

resumeOnProcessFinish in class InvokeProcessActivityBase

Throws:

ActivityException

allSubProcessCompleted

protected boolean allSubProcessCompleted()
                                  throws ActivityException,
                                         org.apache.xmlbeans.XmlException

Specified by:

allSubProcessCompleted in class InvokeProcessActivityBase

Throws:

ActivityException

org.apache.xmlbeans.XmlException

executeServiceSubflowsInSequence

protected void executeServiceSubflowsInSequence(com.centurylink.mdw.microservice.ServicePlan servicePlan)
                                         throws ActivityException

Throws:

ActivityException

executeServiceSubflowsInParallel

protected void executeServiceSubflowsInParallel(com.centurylink.mdw.microservice.ServicePlan servicePlan)
                                         throws ActivityException

Throws:

ActivityException