Fleet.Broadway.Producer (fleet v0.1.0)

Copy Markdown View Source

Broadway producer for Fleet queues, backed by BroadwayPgQue.Producer.

Summary

Functions

transform(raw_msg, ack_ref, ack_data, opts)

Transforms a raw PgQue message map into a structured Fleet.Job wrapped in Broadway.Message.

Functions

transform(raw_msg, ack_ref, ack_data, opts)

Transforms a raw PgQue message map into a structured Fleet.Job wrapped in Broadway.Message.