Class: Liebre::Actor::RPC::Server::Reporter
- Inherits:
-
Object
- Object
- Liebre::Actor::RPC::Server::Reporter
- Defined in:
- lib/liebre/actor/rpc/server/reporter.rb
Instance Method Summary collapse
-
#initialize(context) ⇒ Reporter
constructor
A new instance of Reporter.
- #on_clean ⇒ Object
- #on_failed(error) ⇒ Object
- #on_handle ⇒ Object
- #on_reply ⇒ Object
- #on_start ⇒ Object
- #on_stop ⇒ Object
Constructor Details
#initialize(context) ⇒ Reporter
Returns a new instance of Reporter.
7 8 9 |
# File 'lib/liebre/actor/rpc/server/reporter.rb', line 7 def initialize context @context = context end |
Instance Method Details
#on_clean ⇒ Object
49 50 51 52 53 54 |
# 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.}\n#{error.backtrace}") raise error end |
#on_failed(error) ⇒ Object
41 42 43 44 45 46 47 |
# 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.}\n#{error.backtrace}") yield rescue Exception => error logger.error("Error handling RPC server handler failure: #{name}\n#{error.}\n#{error.backtrace}") raise error end |
#on_handle ⇒ Object
27 28 29 30 31 32 |
# 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.}\n#{error.backtrace}") raise error end |
#on_reply ⇒ Object
34 35 36 37 38 39 |
# 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.}\n#{error.backtrace}") raise error end |
#on_start ⇒ Object
11 12 13 14 15 16 17 |
# 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.}\n#{error.backtrace}") raise error end |
#on_stop ⇒ Object
19 20 21 22 23 24 25 |
# 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.}\n#{error.backtrace}") raise error end |