class

Kiq::Processor

Inherits Reference < Object

Constants

FAILURE = Counter.new
PROCESSED = Counter.new

Constructors

new(config : Config, queues : Array(String), strict : Bool)
Source

Instance methods

config
Source
finished?
Source
process(uow : BasicFetch::UnitOfWork) : Nil
Source
send_to_morgue(msg : Msg) : Nil
Source
send_to_morgue_raw(payload : String) : Nil
Source
start
Source
stopping?
Source
terminate
Source