class Liebre::Actor::RPC::Server::Reporter

Attributes

context[R]

Public Class Methods

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

Public Instance Methods

on_clean() { || ... } click to toggle source
# File lib/liebre/actor/rpc/server/reporter.rb, line 49
def on_clean
  yield
rescue Exception => error
  logger.error("Error cleaning rpc server: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_failed(error) { || ... } click to toggle source
# File lib/liebre/actor/rpc/server/reporter.rb, line 41
def on_failed(error)
  logger.error("Error on RPC server when handling a message #{name}\n#{error.message}\n#{error.backtrace}")
  yield
rescue Exception => error
  logger.error("Error handling RPC server handler failure: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_handle() { || ... } click to toggle source
# File lib/liebre/actor/rpc/server/reporter.rb, line 27
def on_handle
  yield
rescue Exception => error
  logger.error("Error handling request: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_reply() { || ... } click to toggle source
# File lib/liebre/actor/rpc/server/reporter.rb, line 34
def on_reply
  yield
rescue Exception => error
  logger.error("Error replying request: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_start() { || ... } click to toggle source
# File lib/liebre/actor/rpc/server/reporter.rb, line 11
def on_start
  yield
  logger.info("RPC server started: #{name}")
rescue Exception => error
  logger.error("Error starting RPC server: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end
on_stop() { || ... } click to toggle source
# File lib/liebre/actor/rpc/server/reporter.rb, line 19
def on_stop
  yield
  logger.info("RPC server stopped: #{name}")
rescue Exception => error
  logger.error("Error stopping RPC server: #{name}\n#{error.message}\n#{error.backtrace}")
  raise error
end

Private Instance Methods

logger() click to toggle source
# File lib/liebre/actor/rpc/server/reporter.rb, line 62
def logger
  @logger ||= context.logger
end
name() click to toggle source
# File lib/liebre/actor/rpc/server/reporter.rb, line 58
def name
  @name ||= context.name.inspect
end