examples/mq/logger.rb in amqp-0.7.0.pre vs examples/mq/logger.rb in amqp-0.7.0

@@ -1,45 +1,47 @@
+# encoding: utf-8
+
 $:.unshift File.dirname(__FILE__) + '/../../lib'
 require 'mq'
 require 'mq/logger'
 
 Logger = MQ::Logger
 
 AMQP.start(:host => 'localhost') do
   if ARGV[0] == 'server'
 
-    MQ.queue('logger').bind(MQ.fanout('logging', :durable => true)).subscribe{|msg|
+    MQ.queue('logger').bind(MQ.fanout('logging', :durable => true)).subscribe { |msg|
       msg = Marshal.load(msg)
       require 'pp'
       pp(msg)
       puts
     }
 
   elsif ARGV[0] == 'client'
 
     log = Logger.new
     log.debug 'its working!'
-    
+
     log = Logger.new do |msg|
       require 'pp'
       pp msg
       puts
     end
 
     log.info '123'
-    log.debug [1,2,3]
+    log.debug [1, 2, 3]
     log.debug :one => 1, :two => 2
     log.error Exception.new('123')
 
     log.info '123', :process_id => Process.pid
     log.info '123', :process
     log.debug 'login', :session => 'abc', :user => 123
 
     log = Logger.new(:webserver, :timestamp, :hostname, &log.printer)
     log.info 'Request for /', :GET, :session => 'abc'
 
-    AMQP.stop{ EM.stop }
+    AMQP.stop { EM.stop }
 
   else
 
     puts
     puts "#{$0} <client|server>"
@@ -52,37 +54,37 @@
   end
 end
 
 __END__
 
-{:data=>"123", :timestamp=>1216846102, :severity=>:info}
+{:data => "123", :timestamp => 1216846102, :severity => :info}
 
-{:data=>[1, 2, 3], :timestamp=>1216846102, :severity=>:debug}
+{:data => [1, 2, 3], :timestamp => 1216846102, :severity => :debug}
 
-{:data=>
-  {:type=>:exception, :name=>:Exception, :message=>"123", :backtrace=>nil},
- :timestamp=>1216846102,
- :severity=>:error}
+{:data =>
+  {:type => :exception, :name => :Exception, :message => "123", :backtrace => nil},
+ :timestamp => 1216846102,
+ :severity => :error}
 
-{:data=>"123", :timestamp=>1216846102, :process_id=>1814, :severity=>:info}
+{:data => "123", :timestamp => 1216846102, :process_id => 1814, :severity => :info}
 
-{:process=>
-  {:thread_id=>109440,
-   :process_id=>1814,
-   :process_name=>"/Users/aman/code/amqp/examples/logger.rb",
-   :process_parent_id=>1813},
- :data=>"123",
- :timestamp=>1216846102,
- :severity=>:info}
+{:process =>
+  {:thread_id => 109440,
+   :process_id => 1814,
+   :process_name => "/Users/aman/code/amqp/examples/logger.rb",
+   :process_parent_id => 1813},
+ :data => "123",
+ :timestamp => 1216846102,
+ :severity => :info}
 
-{:session=>"abc",
- :data=>"login",
- :timestamp=>1216846102,
- :severity=>:debug,
- :user=>123}
+{:session => "abc",
+ :data => "login",
+ :timestamp => 1216846102,
+ :severity => :debug,
+ :user => 123}
 
-{:session=>"abc",
- :tags=>[:webserver, :GET],
- :data=>"Request for /",
- :timestamp=>1216846102,
- :severity=>:info,
- :hostname=>"gc"}
+{:session => "abc",
+ :tags => [:webserver, :GET],
+ :data => "Request for /",
+ :timestamp => 1216846102,
+ :severity => :info,
+ :hostname => "gc"}