module Circuitry::Processor
Public Instance Methods
flush()
click to toggle source
# File lib/circuitry/processor.rb, line 7 def flush raise NotImplementedError, "#{self} must implement class method `flush`" end
on_exit()
click to toggle source
# File lib/circuitry/processor.rb, line 11 def on_exit Circuitry.subscriber_config.on_async_exit end
process(&_block)
click to toggle source
# File lib/circuitry/processor.rb, line 3 def process(&_block) raise NotImplementedError, "#{self} must implement class method `process`" end
Protected Instance Methods
pool()
click to toggle source
# File lib/circuitry/processor.rb, line 24 def pool @pool ||= [] end
safely_process() { || ... }
click to toggle source
# File lib/circuitry/processor.rb, line 17 def safely_process yield rescue => e logger.error("Error handling message: #{e}") error_handler.call(e) if error_handler end
Private Instance Methods
error_handler()
click to toggle source
# File lib/circuitry/processor.rb, line 34 def error_handler Circuitry.subscriber_config.error_handler end
logger()
click to toggle source
# File lib/circuitry/processor.rb, line 30 def logger Circuitry.subscriber_config.logger end