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

Consumer of all job with error status.

Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

consume(channel, tag, redelivered, payload)

Consume message with error topic, update Job and send a notification.

consume_error_message(channel, tag, payload, job_id, description)

disconnect()

publish_parent_job_error(job, description)

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

consume(channel, tag, redelivered, payload)

Consume message with error topic, update Job and send a notification.

consume_error_message(channel, tag, payload, job_id, description)

disconnect()

publish_parent_job_error(job, description)