Callback logger for Stomp 1.1 heartbeat tests.
Initialize a callback logger class.
# File test/tlogger.rb, line 12 def initialize(init_parms = nil) @log = Logger::new(STDOUT) # User preference @log.level = Logger::DEBUG # User preference @log.info("Logger initialization complete.") end
Log connected events.
# File test/tlogger.rb, line 28 def on_connected(parms) begin @log.debug "Connected: #{info(parms)}" rescue @log.debug "Connected oops" end end
Log connectfail events.
# File test/tlogger.rb, line 37 def on_connectfail(parms) begin @log.debug "Connect Fail #{info(parms)}" rescue @log.debug "Connect Fail oops" end end
Log connecting events.
# File test/tlogger.rb, line 19 def on_connecting(parms) begin @log.debug "Connecting: #{info(parms)}" rescue @log.debug "Connecting oops" end end
Log disconnect events.
# File test/tlogger.rb, line 46 def on_disconnect(parms) begin @log.debug "Disconnected #{info(parms)}" rescue @log.debug "Disconnected oops" end end
Stomp 1.1+ - heart beat thread fires
# File test/tlogger.rb, line 117 def on_hbfire(parms, type, time) begin @log.debug "HBfire #{type} " + "=" * 30 @log.debug "HBfire #{type} Parms #{info(parms)}" @log.debug "HBfire #{type} Time #{time}" rescue @log.debug "HBfire #{type} oops" end end
Stomp 1.1+ - heart beat read (receive) failed
# File test/tlogger.rb, line 107 def on_hbread_fail(parms, ticker_data) begin @log.debug "Hbreadf Parms #{info(parms)}" @log.debug "Hbreadf Result #{ticker_data}" rescue @log.debug "Hbreadf oops" end end
Stomp 1.1+ - heart beat send (transmit) failed
# File test/tlogger.rb, line 96 def on_hbwrite_fail(parms, ticker_data) begin @log.debug "Hbwritef Parms #{info(parms)}" @log.debug "Hbwritef Result #{ticker_data}" rescue @log.debug "Hbwritef oops" end end
Log miscellaneous errors.
# File test/tlogger.rb, line 55 def on_miscerr(parms, errstr) begin @log.debug "Miscellaneous Error #{info(parms)}" @log.debug "Miscellaneous Error String #{errstr}" rescue @log.debug "Miscellaneous Error oops" end end
Log publishes.
# File test/tlogger.rb, line 75 def on_publish(parms, message, headers) begin @log.debug "Publish Parms #{info(parms)}" @log.debug "Publish Message #{message}" @log.debug "Publish Headers #{headers}" rescue @log.debug "Publish oops" end end
Log receives.
# File test/tlogger.rb, line 86 def on_receive(parms, result) begin @log.debug "Receive Parms #{info(parms)}" @log.debug "Receive Result #{result}" rescue @log.debug "Receive oops" end end
Log subscribes.
# File test/tlogger.rb, line 65 def on_subscribe(parms, headers) begin @log.debug "Subscribe Parms #{info(parms)}" @log.debug "Subscribe Headers #{headers}" rescue @log.debug "Subscribe oops" end end