View Source StepFlow.Amqp.WorkerTerminatedConsumer (StepFlow v1.7.0)

Consumer of all worker terminations.

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 worker terminated message.

disconnect()

Link to this section Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

consume(channel, tag, redelivered, payload)

Consume worker terminated message.

disconnect()