OffBroadway.EMQTT.Acknowledger (off_broadway_emqtt v0.3.0)

Copy Markdown View Source

Broadway Acknowledger that sends MQTT ACKs when Broadway messages complete.

For QoS 1/2, this ties Broadway message processing to MQTT acknowledgements, providing protocol-level backpressure via max_inflight.

Summary

Functions

build_ack_data(message, emqtt_pid)

Builds acknowledger data for a message.

Functions

build_ack_data(message, emqtt_pid)

@spec build_ack_data(map(), pid()) :: map()

Builds acknowledger data for a message.