View Source Broadway.CallerAcknowledger (Broadway v1.0.6)
A simple acknowledger that sends a message back to a caller.
It must be stored as:
acknowledger: Broadway.CallerAcknowledger.init({pid, ref}, term)
The first parameter is a tuple with the pid to receive the messages and a unique identifier (usually a reference). The second parameter, which is per message, is ignored.
It sends a message in the format:
{:ack, ref, successful_messages, failed_messages}
If Broadway.Message.configure_ack/2
is called on a message that
uses this acknowledger, then the following message is sent:
{:configure, ref, options}
Link to this section Summary
Functions
Returns the acknowledger metadata.
Link to this section Functions
Returns the acknowledger metadata.