You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2009/01/20 21:33:04 UTC
svn commit: r736094 - /qpid/trunk/qpid/ruby/tests/qmf.rb
Author: tross
Date: Tue Jan 20 12:33:04 2009
New Revision: 736094
URL: http://svn.apache.org/viewvc?rev=736094&view=rev
Log:
QPID-1601 Ruby test patch from Justin Ross
Modified:
qpid/trunk/qpid/ruby/tests/qmf.rb
Modified: qpid/trunk/qpid/ruby/tests/qmf.rb
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/ruby/tests/qmf.rb?rev=736094&r1=736093&r2=736094&view=diff
==============================================================================
--- qpid/trunk/qpid/ruby/tests/qmf.rb (original)
+++ qpid/trunk/qpid/ruby/tests/qmf.rb Tue Jan 20 12:33:04 2009
@@ -28,8 +28,10 @@
# Make sure errors in threads lead to a noisy death of the test
Thread.abort_on_exception = true
- sock = TCPSocket.new(ENV.fetch("QMF_TEST_HOST", 'localhost'),
- ENV.fetch("QMF_TEST_PORT", 5672))
+ host = ENV.fetch("QMF_TEST_HOST", 'localhost')
+ port = ENV.fetch("QMF_TEST_PORT", 5672)
+
+ sock = TCPSocket.new(host, port)
@conn = Qpid::Connection.new(sock)
@conn.start()
@@ -39,7 +41,7 @@
# It's a bit odd that we're using two connections but that's the way
# the python one works afaict.
@qmf = Qpid::Qmf::Session.new()
- @qmf_broker = @qmf.add_broker("amqp://localhost:5672")
+ @qmf_broker = @qmf.add_broker("amqp://%s:%d" % [host, port])
brokers = @qmf.objects(:class => "broker")
assert_equal(1, brokers.length)
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org