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