/usr/share/doc/ruby-amqp/examples/legacy/logger.rb is in ruby-amqp 0.9.5-2.
This file is owned by root:root, with mode 0o755.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 | #!/usr/bin/env ruby
# encoding: utf-8
require "bundler"
Bundler.setup
$:.unshift(File.expand_path("../../../lib", __FILE__))
require 'amqp'
require 'amqp/logger'
AMQP.start(:host => 'localhost') do
if ARGV[0] == 'server'
AMQP::Channel.new.queue('logger').bind(AMQP::Channel.new.fanout('logging', :durable => true)).subscribe { |msg|
msg = Marshal.load(msg)
require 'pp'
pp(msg)
puts
}
elsif ARGV[0] == 'client'
log = AMQP::Logger.new
log.debug 'its working!'
log = AMQP::Logger.new do |msg|
require 'pp'
pp msg
puts
end
log.info '123'
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 = AMQP::Logger.new(:webserver, :timestamp, :hostname, &log.printer)
log.info 'Request for /', :GET, :session => 'abc'
AMQP.stop { EM.stop }
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
__END__
{:data => "123", :timestamp => 1216846102, :severity => :info}
{:data => [1, 2, 3], :timestamp => 1216846102, :severity => :debug}
{:data =>
{:type => :exception, :name => :Exception, :message => "123", :backtrace => nil},
:timestamp => 1216846102,
:severity => :error}
{: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}
{:session => "abc",
:data => "login",
:timestamp => 1216846102,
:severity => :debug,
:user => 123}
{:session => "abc",
:tags => [:webserver, :GET],
:data => "Request for /",
:timestamp => 1216846102,
:severity => :info,
:hostname => "gc"}
|