Sha256: 92dd8a83b5532af048ad2b1760d6d8e1ed7c288000b2d8183b38f2dbe93ff1e5
Contents?: true
Size: 1.59 KB
Versions: 1
Compression:
Stored size: 1.59 KB
Contents
require 'rubygems' require 'stomp' # require 'test/unit' $:.unshift File.dirname(__FILE__) require 'test_0000_base' # # Test "ack" and :ack on a subscribe to a Stomp Connection. # class Test_0015_Ack_Conn < Test_0000_Base # Setup. # * Open a Stomp Connection # * Set the test queue name # * Set the message to use. # * Set counter for looping tests def setup super open_conn() @queuename = "/queue/connack/" + name @test_message = "What's up doc?" @times = 10 # end # Teardown. # # Connection disconnect. def teardown disconnect_conn() end # Test ACK of a single message def test_0010_ack_conn_one ack_conn_test("ack") end =begin # Test ACK of a single message using symbol header def test_0020_ack_conn_one_sym ack_conn_test(:ack) end # Test ACK of multiple messages def test_0030_ack_conn_mult ack_conn_test("ack", @times) end # Test ACK of multiple messages using symbol header def test_0040_ack_conn_mult_sym ack_conn_test(:ack, @times) end =end private def ack_conn_test(ackparm = nil, ntimes = 1) # received = nil assert_nothing_raised() { ntimes.times do |n| @conn.publish(@queuename, "#{@test_message} #{n+1}") end } # connection_subscribe(@queuename, { ackparm => "client" }) # count = 0 assert_nothing_raised() { ntimes.times do |n| received = @conn.receive @conn.ack(received.headers["message-id"]) count += 1 end } # assert_equal(ntimes,count,"count should be the same: #{@queuename}") end end # of class
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
stompserver_ng-1.0.6 | test/test_0015_ack_conn.rb |