examples/logexamp.rb in stomp-1.2.4 vs examples/logexamp.rb in stomp-1.2.5

@@ -2,66 +2,80 @@
 
 require 'rubygems'
 require 'stomp'
 require 'logger'  # for the 'local' logger
 #
-$:.unshift(File.dirname(__FILE__))
+if Kernel.respond_to?(:require_relative)
+  require_relative("./slogger")
+else
+  $LOAD_PATH << File.dirname(__FILE__)
+  require "slogger"
+end
 #
-require 'slogger'
+# == A STOMP::Connection program which uses the callback logging facility.
 #
-# A STOMP::Connection program which uses the callback logging facility.
-#
-llog =        Logger::new(STDOUT)
-llog.level =  Logger::DEBUG
-llog.debug "LE Starting"
+class LoggerExample
+  # Initialize.
+  def initialize
+  end
+  # Run example.
+  def run
+    llog =        Logger::new(STDOUT)
+    llog.level =  Logger::DEBUG
+    llog.debug "LE Starting"
 
-# //////////////////////////////////////////////////////////////////////////////
-mylog = Slogger::new  # The client provided STOMP callback logger
+    # //////////////////////////////////////////////////////////////////////////////
+    mylog = Slogger::new  # The client provided STOMP callback logger
 
-# //////////////////////////////////////////////////////////////////////////////
-user =      ENV['STOMP_USER'] ? ENV['STOMP_USER'] : 'guest'
-password =  ENV['STOMP_PASSWORD'] ? ENV['STOMP_PASSWORD'] : 'guest'
-host =      ENV['STOMP_HOST'] ? ENV['STOMP_HOST'] : 'localhost'
-port =      ENV['STOMP_PORT'] ? ENV['STOMP_PORT'].to_i : 61613
-# //////////////////////////////////////////////////////////////////////////////
-# A hash type connect *MUST* be used to enable callback logging.
-# //////////////////////////////////////////////////////////////////////////////
-hash = { :hosts => [ 
-          {:login => user, :passcode => password, :host => 'noonehome', :port => 2525},
-          {:login => user, :passcode => password, :host => host, :port => port},
-          ],
-          :logger => mylog,	# This enables callback logging!
-          :max_reconnect_attempts => 5,
-        }
+    # //////////////////////////////////////////////////////////////////////////////
+    user =      ENV['STOMP_USER'] ? ENV['STOMP_USER'] : 'guest'
+    password =  ENV['STOMP_PASSWORD'] ? ENV['STOMP_PASSWORD'] : 'guest'
+    host =      ENV['STOMP_HOST'] ? ENV['STOMP_HOST'] : 'localhost'
+    port =      ENV['STOMP_PORT'] ? ENV['STOMP_PORT'].to_i : 61613
+    # //////////////////////////////////////////////////////////////////////////////
+    # A hash type connect *MUST* be used to enable callback logging.
+    # //////////////////////////////////////////////////////////////////////////////
+    hash = { :hosts => [
+        {:login => user, :passcode => password, :host => 'noonehome', :port => 2525},
+        {:login => user, :passcode => password, :host => host, :port => port},
+      ],
+      :logger => mylog,	# This enables callback logging!
+      :max_reconnect_attempts => 5,
+    }
 
-# //////////////////////////////////////////////////////////////////////////////
-# For a Connection:
-llog.debug "LE Connection processing starts"
-conn = Stomp::Connection.new(hash)
-conn.disconnect
-# //////////////////////////////////////////////////////////////////////////////
-llog.debug "LE Connection processing complete"
+    # //////////////////////////////////////////////////////////////////////////////
+    # For a Connection:
+    llog.debug "LE Connection processing starts"
+    conn = Stomp::Connection.new(hash)
+    conn.disconnect
+    # //////////////////////////////////////////////////////////////////////////////
+    llog.debug "LE Connection processing complete"
 
-# //////////////////////////////////////////////////////////////////////////////
-# For a Client:
-llog.debug "LE Client processing starts"
-conn = Stomp::Client.new(hash)
-conn.close
-# //////////////////////////////////////////////////////////////////////////////
-llog.debug "LE Client processing complete"
+    # //////////////////////////////////////////////////////////////////////////////
+    # For a Client:
+    llog.debug "LE Client processing starts"
+    conn = Stomp::Client.new(hash)
+    conn.close
+    # //////////////////////////////////////////////////////////////////////////////
+    llog.debug "LE Client processing complete"
 
-# //////////////////////////////////////////////////////////////////////////////
-# For a Connection with other calls:
-llog.debug "LE Connection Enhanced processing starts"
-conn = Stomp::Connection.new(hash)
-#
-dest = "/queue/loggerq1"
-conn.publish dest, "a logger message"
-conn.subscribe dest
-msg = conn.receive
-conn.disconnect
-# //////////////////////////////////////////////////////////////////////////////
-llog.debug "LE Connection Enhanced processing complete"
+    # //////////////////////////////////////////////////////////////////////////////
+    # For a Connection with other calls:
+    llog.debug "LE Connection Enhanced processing starts"
+    conn = Stomp::Connection.new(hash)
+    #
+    dest = "/queue/loggerq1"
+    conn.publish dest, "a logger message"
+    conn.subscribe dest
+    msg = conn.receive
+    conn.disconnect
+    # //////////////////////////////////////////////////////////////////////////////
+    llog.debug "LE Connection Enhanced processing complete"
 
-# //////////////////////////////////////////////////////////////////////////////
-llog.debug "LE Ending"
+    # //////////////////////////////////////////////////////////////////////////////
+    llog.debug "LE Ending"
+  end
+end
+e = LoggerExample.new
+e.run
+