From ff7caa01f47df249066169daa314664c3669842e Mon Sep 17 00:00:00 2001
From: Martin Lucina <martin@lucina.net>
Date: Wed, 9 Nov 2011 18:51:46 +0100
Subject: Initial commit

---
 test-notifier.rb | 55 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 55 insertions(+)
 create mode 100755 test-notifier.rb

(limited to 'test-notifier.rb')

diff --git a/test-notifier.rb b/test-notifier.rb
new file mode 100755
index 0000000..1adeb20
--- /dev/null
+++ b/test-notifier.rb
@@ -0,0 +1,55 @@
+#!/usr/bin/env ruby
+#
+#  test-notifier.rb: Dump all messages received from notifier.
+#
+#  Copyright (C) 2011 VMware, Inc.
+# 
+#  Permission is hereby granted, free of charge, to any person obtaining a copy
+#  of this software and associated documentation files (the "Software"), to deal
+#  in the Software without restriction, including without limitation the rights
+#  to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+#  copies of the Software, and to permit persons to whom the Software is
+#  furnished to do so, subject to the following conditions:
+#  
+#  The above copyright notice and this permission notice shall be included in
+#  all copies or substantial portions of the Software.
+# 
+#  THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+#  IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+#  FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+#  AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+#  LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+#  OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+#  THE SOFTWARE.
+
+require 'ffi-rzmq'
+
+trap("INT") { exit }
+trap("TERM") { exit }
+def raise_if_error(rc)
+  unless ZMQ::Util.resultcode_ok?(rc)
+    raise "ZMQ Error: #{ZMQ::Util.error_string}"
+  end
+end
+
+unless ARGV[0]
+  print "usage: test-notifier.rb <notifier-host>\n"
+  exit 1
+end
+
+notifier_ep = "tcp://#{ARGV[0]}:7771"
+
+ctx = ZMQ::Context.new()
+notifier_sock = ctx.socket(ZMQ::SUB)
+rc = notifier_sock.setsockopt(ZMQ::SUBSCRIBE, '')
+raise_if_error(rc)
+rc = notifier_sock.connect(notifier_ep)
+raise_if_error(rc)
+
+msg = ''
+loop do
+  rc = notifier_sock.recv_string(msg, 0)
+  raise_if_error(rc)
+  print "[#{Time.now}] #{msg}\n"
+end
+
-- 
cgit v1.2.3