PhoenixMicro.Consumer.Worker (PhoenixMicro v1.0.0)

GenServer that manages the lifecycle of a single consumer subscription: subscribing to the transport, invoking the consumer module, and applying retry + DLQ logic.

Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

start_link(consumer_module, opts \\ [])

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(consumer_module, opts \\ [])

@spec start_link(
  module(),
  keyword()
) :: GenServer.on_start()