View Source StepFlow.Amqp.ProgressionConsumer (StepFlow v1.8.0)

Consumer of all progression jobs.

Summary

Functions

Returns a specification to start this module under a supervisor.

Consume message with job progression and save it in database.

Functions

Link to this function

add_progression(channel, tag, job, payload)

View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

consume(channel, tag, redelivered, payload)

View Source

Consume message with job progression and save it in database.

Link to this function

error_status_check(channel, tag, job, payload, last_status)

View Source