Ruby: emit_log_direct.rb

ruby/emit_log.rb

@@ -6,7 +6,7 @@ require "amqp"
 AMQP.start(:host => "localhost") do |connection|
   channel  = AMQP::Channel.new(connection)
   exchange = channel.fanout("logs")
-  message  = (ARGV[1..-1] || ["info: Hello World!"]).join(" ")
+  message  = (ARGV[0..-1] || ["info: Hello World!"]).join(" ")
 
   exchange.publish(message)
   puts " [x] Sent #{message}"

ruby/emit_log_direct.rb

@@ -0,0 +1,20 @@
+#!/usr/bin/env ruby
+# encoding: utf-8
+
+require "amqp"
+
+AMQP.start(:host => "localhost") do |connection|
+  channel  = AMQP::Channel.new(connection)
+  exchange = channel.direct("direct_logs")
+  severity = ARGV[0] || "info"
+  message  = (ARGV[1..-1] || ["Hello World!"]).join(" ")
+
+  exchange.publish(message, :routing_key => severity)
+  puts " [x] Sent #{severity}:#{message}"
+
+  EM.add_timer(0.5) do
+    connection.close do
+      EM.stop { exit }
+    end
+  end
+end