# File test/test_client.rb, line 410 def test_thread_one_subscribe msg = nil dest = make_destination Thread.new(@client) do |acli| assert_nothing_raised { if acli.protocol() == Stomp::SPL_10 acli.subscribe(dest) { |m| msg = m } else acli.subscribe(dest, :id => acli.uuid()) { |m| msg = m } end Timeout::timeout(4) do sleep 0.01 until msg end } end # @client.publish(dest, message_text) sleep 1 assert_not_nil msg checkEmsg(@client) end