class Liebre::Actor::Consumer::Reporter

Attributes

context[R]

Public Class Methods

new(context) click to toggle source
# File lib/liebre/actor/consumer/reporter.rb, line 6
def initialize context
  @context = context
end

Public Instance Methods

on_ack() { || ... } click to toggle source
# File lib/liebre/actor/consumer/reporter.rb, line 33
def on_ack
  yield
rescue Exception => error
  logger.error("Error acking: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_clean() { || ... } click to toggle source
# File lib/liebre/actor/consumer/reporter.rb, line 62
def on_clean
  yield
rescue Exception => error
  logger.error("Error cleaning consumer: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_consume() { || ... } click to toggle source
# File lib/liebre/actor/consumer/reporter.rb, line 26
def on_consume
  yield
rescue Exception => error
  logger.error("Error consuming: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_failed(error) { || ... } click to toggle source
# File lib/liebre/actor/consumer/reporter.rb, line 54
def on_failed error
  logger.error("Error on Consumer when handling a message #{name}\n#{error.message}\n#{error.backtrace}")
  yield
rescue Exception => error
  logger.error("Error handling consumer handler failure: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_nack() { || ... } click to toggle source
# File lib/liebre/actor/consumer/reporter.rb, line 40
def on_nack
  yield
rescue Exception => error
  logger.error("Error nacking: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_reject() { || ... } click to toggle source
# File lib/liebre/actor/consumer/reporter.rb, line 47
def on_reject
  yield
rescue Exception => error
  logger.error("Error rejecting: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_start() { || ... } click to toggle source
# File lib/liebre/actor/consumer/reporter.rb, line 10
def on_start
  yield
  logger.info("Consumer started: #{name}")
rescue Exception => error
  logger.error("Error starting consumer: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_stop() { || ... } click to toggle source
# File lib/liebre/actor/consumer/reporter.rb, line 18
def on_stop
  yield
  logger.info("Consumer stopped: #{name}")
rescue Exception => error
  logger.error("Error stopping consumer: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end

Private Instance Methods

logger() click to toggle source
# File lib/liebre/actor/consumer/reporter.rb, line 75
def logger
  @logger ||= context.logger
end
name() click to toggle source
# File lib/liebre/actor/consumer/reporter.rb, line 71
def name
  @name ||= context.name.inspect
end