StepFlow.Amqp.CompletedConsumer (StepFlow v0.2.5) View Source

Consumer of all job with completed status.

Link to this section Summary

Functions

Returns a specification to start this module under a supervisor.

Consume messages with completed topic, update Job status and continue the workflow.

Link to this section Functions

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

consume(channel, tag, redelivered, payload)

View Source

Consume messages with completed topic, update Job status and continue the workflow.