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