def test_nack11p_0010
if @conn.protocol == Stomp::SPL_10
assert_raise Stomp::Error::UnsupportedProtocolError do
@conn.nack "dummy msg-id"
end
else
dest = make_destination
smsg = "test_stomp#test_nack01: #{Time.now.to_f}"
@conn.publish dest, smsg
sid = @conn.uuid()
@conn.subscribe dest, :ack => :client, :id => sid
msg = @conn.receive
assert_equal smsg, msg.body
case @conn.protocol
when Stomp::SPL_12
assert_nothing_raised {
@conn.nack msg.headers["ack"]
sleep 0.05
@conn.unsubscribe dest, :id => sid
}
else
assert_nothing_raised {
@conn.nack msg.headers["message-id"], :subscription => sid
sleep 0.05
@conn.unsubscribe dest, :id => sid
}
end
teardown()
setup()
sid = @conn.uuid()
@conn.subscribe dest, :ack => :auto, :id => sid
msg2 = @conn.receive
assert_equal smsg, msg2.body
checkEmsg(@conn)
end
end