class

KemalcrStarter::Infrastructure::DB::OutboxEventRepository

Instance methods

create(event : Core::Events::DomainEvent, connection : ::DB::Connection) : Nil

create(event : Core::Events::DomainEvent) : Nil

find(id : String) : OutboxEventRecord | Nil

increment_retry(event_id : String, error_message : String | Nil, backoff_seconds : Int32 = 0) : Nil

list_dead_letters

mark_dead(event_id : String, error_message : String | Nil, connection : ::DB::Connection) : Nil

mark_dead(event_id : String, error_message : String | Nil) : Nil

mark_dispatched(event_id : String, connection : ::DB::Connection) : Nil

mark_dispatched(event_id : String) : Nil

move_to_dead_letter(event_id : String, failure_reason : String | Nil) : Nil

next_batch(batch_size : Int32 = 50) : Array(OutboxEventRecord)

reclaim_stale_in_progress(stale_threshold_seconds : Int32 = 30) : Int32

requeue_dead_letter(dead_letter_id : String) : Bool