Proca.Stage.SQS behaviour (proca v3.0.2)

Processing "stage" that sends data to SQS

Link to this section Summary

Link to this section Callbacks

Link to this callback

process_name(name, base_name)

Specs

process_name(Broadway.name(), base_name :: String.t()) :: Broadway.name()

Link to this section Functions

Link to this function

mark_failed(messages, map)

Link to this function

process_name(broadway_name, base_name)

Link to this function

start_for?(org)

Link to this function

start_link(org)

Link to this function

to_message(body)

Link to this function

to_message_attributes(body)