examples/slogger.rb in stomp-1.1.10 vs examples/slogger.rb in stomp-1.2.0

@@ -1,5 +1,7 @@
+# -*- encoding: utf-8 -*-
+
 =begin
 
 Example STOMP call back logger class.
 
 Optional callback methods:
@@ -9,10 +11,14 @@
     on_connectfail: unsuccessful connect (will usually be retried)
     on_disconnect: successful disconnect
 
     on_miscerr: on miscellaneous xmit/recv errors
 
+    on_publish: publish called
+    on_subscribe: subscribe called
+    on_receive: receive called and successful
+
 All methods are optional, at the user's requirements.
 
 If a method is not provided, it is not called (of course.)
 
 IMPORTANT NOTE:  call back logging methods *MUST* not raise exceptions, 
@@ -67,17 +73,89 @@
     rescue
       @log.debug "Disconnected oops"
     end
   end
 
-
   # Log miscellaneous errors
   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
+
+  # Subscribe
+  def on_subscribe(parms, headers)
+    begin
+      @log.debug "Subscribe Parms #{info(parms)}"
+      @log.debug "Subscribe Headers #{headers}"
+    rescue
+      @log.debug "Subscribe oops"
+    end
+  end
+
+  # Publish
+  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
+
+  # Receive
+  def on_receive(parms, result)
+    begin
+      @log.debug "Receive Parms #{info(parms)}"
+      @log.debug "Receive Result #{result}"
+    rescue
+      @log.debug "Receive oops"
+    end
+  end
+
+  # Stomp 1.1+ - heart beat read (receive) failed
+  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
+  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
+
+
+  # Stomp 1.1+ - heart beat read (receive) failed
+  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 thread fires
+  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
 
   private