Skip to main content

Module queue

Module queue 

Source
Expand description

Queue-based Stripe webhook dispatch (eventual-consistency path).

ProcessStripeWebhook is a ferro_queue::Job that holds a raw Stripe event body and dispatches it through a shared SyncDispatcher on the background worker. The same dispatcher instance serves both the synchronous HTTP path and the queue path — register handlers once with SyncDispatcher::on and enqueue this job for events that tolerate eventual consistency.

§Persistence

The job persists event_type and raw_body through serde. The dispatcher field is runtime-only (#[serde(skip)]) and must be re-injected by the caller at enqueue time via ProcessStripeWebhook::new. Jobs deserialized without a dispatcher will return ferro_queue::Error::JobFailed on handle so the queue can mark the job failed and continue processing other jobs.

Structs§

ProcessStripeWebhook
Background job that dispatches a verified Stripe webhook event through a shared SyncDispatcher.