StepFlow v0.2.7

StepFlow.Amqp.ProgressionConsumer (StepFlow v0.2.7) View Source

Consumer of all progression jobs.

Link to this section Summary

Functions

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.

Link to this section Functions

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.