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

Consumer of all progression jobs.

Summary

Functions

add_progression(channel, tag, job, payload)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

consume(channel, tag, redelivered, payload)

Consume message with job progression and save it in database.

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

Functions

Link to this function

add_progression(channel, tag, job, payload)

View Source
Link to this function

child_spec(init_arg)

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

disconnect()

View Source
Link to this function

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

View Source