[Ubermq-commits] jms/src/com/ubermq/jms/client/test RegressionTestCase.java,1.15,1.15.2.1
Brought to you by:
jimmyp
From: <ji...@us...> - 2002-10-08 19:50:09
|
Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/client/test In directory usw-pr-cvs1:/tmp/cvs-serv17612/src/com/ubermq/jms/client/test Modified Files: Tag: ubermq-1-0 RegressionTestCase.java Log Message: multicast fixes Index: RegressionTestCase.java =================================================================== RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/test/RegressionTestCase.java,v retrieving revision 1.15 retrieving revision 1.15.2.1 diff -C2 -d -r1.15 -r1.15.2.1 *** RegressionTestCase.java 30 Sep 2002 21:21:58 -0000 1.15 --- RegressionTestCase.java 8 Oct 2002 19:50:05 -0000 1.15.2.1 *************** *** 16,567 **** */ public class RegressionTestCase ! extends TestCase { ! public static TestSuite suite() { ! return new TestSuite(RegressionTestCase.class); ! } ! ! public RegressionTestCase(String sz) { ! super(sz); [...1087 lines suppressed...] ! ! public static void receiveOrdered(TopicSubscriber s, ! int startingAt, ! int n) ! throws JMSException ! { ! int lastSequence=0; ! ! for (int i = 0; i < n; i++) ! { ! Message m = s.receive(RECV_TIMEOUT); ! Assert.assertNotNull(m); ! Assert.assertEquals(i + startingAt, m.getIntProperty("ordinal")); ! Assert.assertTrue( ((LocalMessage)m).getSequence() > lastSequence ); ! m.acknowledge(); ! ! lastSequence = ((LocalMessage)m).getSequence(); ! } ! } } |