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

Consumer of Worker Descriptions.

Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

consume(channel, tag, redelivered, payload)

Consume messages, create Worker Definition if it's not already declared.

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, create Worker Definition if it's not already declared.

Link to this function

disconnect()

View Source