class

EventBus::Task

Constants

MAX_FETCH_ATTEMPTS = 10

Hard cap on connection-error retries even when @retry_count requests unlimited.

NOT_FOUND_ATTEMPTS = 3

A row that is genuinely absent (e.g. removed by retention cleanup) will never appear, so give up quickly instead of looping forever and wedging the worker pool.

Constructors

new(event : DBEvent, receivers : Array(EventBus::EventHandler), pool : DB::Database, retry_count : Int32)

Source

Instance methods

event

pool

receivers

run