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

Consumer of all job with stopped status.

Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

consume(channel, tag, redelivered, payload)

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

disconnect()

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 messages with stopped topic, update Job status and continue the workflow.

Link to this function

disconnect()

View Source