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