Skip to content

Latest commit

 

History

History
119 lines (74 loc) · 2.81 KB

Process.md

File metadata and controls

119 lines (74 loc) · 2.81 KB
Raw

Process

new Process(processDefinition, context)

Arguments:

  • processDefinition: process definition object from serializable context
  • context: shared context

Process properties:

  • id: process id
  • type: process type
  • name: process name
  • isExecutable: boolean indicating that the process is executable
  • broker: process broker
  • context: passed shared context
  • counters: counters for completed runs etc
  • environment: shared environment
  • execution: getter for current execution instance
  • executionId: current unique execution id
  • isRunning: boolean indicating if the process is running
  • logger: process logger instance
  • parent: process parent
    • id: id of parent
    • type: parent type
  • status: current status
  • stopped: boolean indicating if the process is in a stopped state
  • lanes: list of process Lane instances

getApi(message)

Get process or activity api.

Arguments:

  • message: process or activity broker message

Returns api.

getActivities()

Get all process activity instances.

getActivityById(id)

Get activity instance by id.

getLaneById(id)

Get process swim lane by id.

getSequenceFlows()

Get all process sequences flows.

getPostponed()

Get all activities that are in a postponed state, e.g. waiting for user input.

getState()

Get process state.

on(eventName, handler[, eventOptions])

Listen for events.

Arguments:

  • eventName: name of event
  • handler: required function called when events occur
    • api: activity or process api
  • eventOptions: passed to underlying broker as consume options

once(eventName, handler[, eventOptions])

Listen for event.

Arguments:

  • eventName: name of event
  • handler: required function called when event occur
    • api: activity or process api
  • eventOptions: passed to underlying broker as consume options

recover([state])

Recover process from state.

Returns process.

resume()

Resume process from a stopped or recovered state.

Returns process.

run()

Run process.

stop()

Stop process run.

waitFor(eventName[, onMessage])

Wait for event to occur as promised.

Arguments:

  • eventName: name of event
  • onMessage: optional message callback for event filtering purposes. Return false if the promise should not resolve. Called with the following arguments
    • routingKey: broker message routing key
    • message: actual message that match event name
    • owner: broker owner, in this case probably the actual activity

Returns Promise that will resolve with element api on event name or reject on error.