ActivityExecution.md

Activity execution

Shared activity execution.

• new ActivityExecution(activity, context)
  • activate()
  • deactivate()
  • discard()
  • execute(executeMessage)
  • passthrough(executeMessage)
  • getApi(message)
  • getPostponed()
  • getState()
  • recover([state])
  • stop()

new ActivityExecution(activity, context)

Arguments:

• activity: parent activity function
• context: shared context

Properties:

• completed: has execution completed
• source: instance of activity behaviour

activate()

Bind the execute queue and start consuming execute and api messages. Called internally when an activity begins executing.

deactivate()

Cancel execute and api consumers and unbind the execute queue. Counterpart to activate().

discard()

Discard execution.

execute(executeMessage)

Execute activity behaviour with message.

passthrough(executeMessage)

Pass an execute message straight to the behaviour, executing first if no source is set up yet. Used by loop characteristics for multi-instance iterations.

getApi(message)

Get activity api.

getPostponed()

Get activity executions that are in a postponed state. Returns list of api.

getState()

Get activity execution state.

recover([state])

Recover activity execution state.

stop()

Stop execution