# File test/test_anonymous.rb, line 282 def test_thread_poll_one received = nil max_sleep = (RUBY_VERSION =~ /1\.8/) ? 10 : 1 Thread.new(@conn) do |amq| while true received = amq.poll # One message is needed Thread.exit if received sleep max_sleep end end # conn_subscribe( make_destination ) message = Time.now.to_s @conn.publish(make_destination, message) sleep max_sleep+1 assert_not_nil received assert_equal message, received.body checkEmsg(@conn) end