Class: OpenLoam::EventRedeliverySweepJob

Inherits:
ActiveJob::Base
  • Object
show all
Defined in:
app/jobs/open_loam/event_redelivery_sweep_job.rb

Overview

Periodic durability sweep: re-enqueues due-but-undelivered event deliveries whose accelerator job was lost (worker crash, dropped message, an async adapter racing the creating transaction). This — not perform_later at publish — is what makes persistent delivery durable.

Registered per-tenant via OpenLoam::Scheduler (see OpenLoam::Engine), so sync_tenant materializes a schedule row per tenant and the scheduler allowlist already covers the class. Tenant-scoped: the scheduler enqueues it with tenant_id and the sweep runs inside that tenant, so there is no cross-tenant scan.

Instance Method Summary collapse

Instance Method Details

#perform(tenant_id: nil) ⇒ Object 



14
15
16
17
18
19
 
# File 'app/jobs/open_loam/event_redelivery_sweep_job.rb', line 14

def perform(tenant_id: nil)
  tenant = OpenLoam::Tenant.find_by(id: tenant_id)
  return if tenant.nil?

  OpenLoam.as_tenant(tenant) { OpenLoam::DurableEvents.redeliver_stuck }
end