View Source OffBroadwaySequin.Producer (off_broadway_sequin v0.1.0)

A GenStage Producer for Sequin.

Broadway producer acts as a consumer for the specified Sequin stream.

Producer Options

• :stream - Required. Sequin stream name.

• :consumer - Required. Sequin consumer name.

• :receive_interval - Optional. The duration (in milliseconds) for which the producer waits before making a request for more messages if there are no events in stream. Default is 1000.

Acknowledgements

Both successful and failed messages are acknowledged by default. Use Broadway.Message.configure_ack/2 to change this behaviour for failed messages.

Message Data

Message data is a map containing :ack_id, :data, and :subject fields.