class EventBus::Task

Defined in:

eventbus/task.cr

Constant Summary

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

Instance Method Summary

Constructor Detail

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

[View source]

Instance Method Detail

def event : DBEvent #

[View source]
def id #

[View source]
def pool : DB::Database #

[View source]
def receivers : Array(EventHandler) #

[View source]
def run #

[View source]