examples/mq/logger.rb in amqp-0.5.9 vs examples/mq/logger.rb in amqp-0.6.0
- old
+ new
@@ -11,13 +11,13 @@
msg = Marshal.load(msg)
require 'pp'
pp(msg)
puts
}
-
- else
+ elsif ARGV[0] == 'client'
+
log = Logger.new
log.debug 'its working!'
log = Logger.new do |msg|
require 'pp'
@@ -36,9 +36,19 @@
log = Logger.new(:webserver, :timestamp, :hostname, &log.printer)
log.info 'Request for /', :GET, :session => 'abc'
AMQP.stop{ EM.stop_event_loop }
+
+ else
+
+ puts
+ puts "#{$0} <client|server>"
+ puts " client: send logs to message queue"
+ puts " server: read logs from message queue"
+ puts
+
+ EM.stop
end
}
__END__