examples/slogger.rb in stomp-1.2.9 vs examples/slogger.rb in stomp-1.2.10

@@ -13,10 +13,18 @@
 #
 # *    on_miscerr: on miscellaneous xmit/recv errors
 #
 # *    on_publish: publish called
 # *    on_subscribe: subscribe called
+# *    on_unsubscribe: unsubscribe called
+#
+# *    on_begin: begin called
+# *    on_ack: ack called
+# *    on_nack: nack called
+# *    on_commit: commit called
+# *    on_abort: abort called
+#
 # *    on_receive: receive called and successful
 #
 # *    on_ssl_connecting: SSL connection starting
 # *    on_ssl_connected: successful SSL connect
 # *    on_ssl_connectfail: unsuccessful SSL connect (will usually be retried)
@@ -78,11 +86,11 @@
       @log.debug "Connect Fail oops"
     end
 =begin
     # An example LoggerConnectionError raise
     @log.debug "Connect Fail, will raise"
-    raise Stomp::Error::LoggerConnectionError.new("quit from connect")
+    raise Stomp::Error::LoggerConnectionError.new("quit from connect fail")
 =end
   end
 
   # Log disconnect events
   def on_disconnect(parms)
@@ -111,10 +119,20 @@
     rescue
       @log.debug "Subscribe oops"
     end
   end
 
+  # Log UnSubscribe
+  def on_unsubscribe(parms, headers)
+    begin
+      @log.debug "UnSubscribe Parms #{info(parms)}"
+      @log.debug "UnSubscribe Headers #{headers}"
+    rescue
+      @log.debug "UnSubscribe oops"
+    end
+  end
+
   # Log Publish
   def on_publish(parms, message, headers)
     begin
       @log.debug "Publish Parms #{info(parms)}"
       @log.debug "Publish Message #{message}"
@@ -132,24 +150,74 @@
     rescue
       @log.debug "Receive oops"
     end
   end
 
+  # Log Begin
+  def on_begin(parms, headers)
+    begin
+      @log.debug "Begin Parms #{info(parms)}"
+      @log.debug "Begin Result #{headers}"
+    rescue
+      @log.debug "Begin oops"
+    end
+  end
+
+  # Log Ack
+  def on_ack(parms, headers)
+    begin
+      @log.debug "Ack Parms #{info(parms)}"
+      @log.debug "Ack Result #{headers}"
+    rescue
+      @log.debug "Ack oops"
+    end
+  end
+
+  # Log NAck
+  def on_nack(parms, headers)
+    begin
+      @log.debug "NAck Parms #{info(parms)}"
+      @log.debug "NAck Result #{headers}"
+    rescue
+      @log.debug "NAck oops"
+    end
+  end
+
+  # Log Commit
+  def on_commit(parms, headers)
+    begin
+      @log.debug "Commit Parms #{info(parms)}"
+      @log.debug "Commit Result #{headers}"
+    rescue
+      @log.debug "Commit oops"
+    end
+  end
+
+  # Log Abort
+  def on_abort(parms, headers)
+    begin
+      @log.debug "Abort Parms #{info(parms)}"
+      @log.debug "Abort Result #{headers}"
+    rescue
+      @log.debug "Abort 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}"
+      @log.debug "Hbreadf Result #{ticker_data.inspect}"
     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}"
+      @log.debug "Hbwritef Result #{ticker_data.inspect}"
     rescue
       @log.debug "Hbwritef oops"
     end
   end