Update of /cvsroot/openjms/openjms/src/testharness/org/exolab/testharness/jms/bugs
In directory sc8-pr-cvs1:/tmp/cvs-serv24861
Modified Files:
TestBug889.java
Log Message:
Increased the timeout to wait for messages for the benefit of the http connector which occasionally wouldn't receive all messages in the 5 second timeframe
Index: TestBug889.java
===================================================================
RCS file: /cvsroot/openjms/openjms/src/testharness/org/exolab/testharness/jms/bugs/TestBug889.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -C2 -d -r1.4 -r1.5
*** TestBug889.java 16 Jan 2003 13:45:13 -0000 1.4
--- TestBug889.java 18 Jan 2003 01:40:19 -0000 1.5
***************
*** 141,145 ****
receiver.setMessageListener(listener);
! Thread.currentThread().sleep(5000);
assertEquals(
--- 141,157 ----
receiver.setMessageListener(listener);
!
! // loop for a maximum of 10 seconds while we wait for
! // the receiver to receive 10 messages
! for (int index = 0; index < 100; index ++) {
! if (listener.getMessageCount() == 10) {
! break;
! } else {
! try {
! Thread.sleep(100);
! } catch (InterruptedException ignore) {
! }
! }
! }
assertEquals(
***************
*** 148,152 ****
session.rollback();
! Thread.currentThread().sleep(5000);
assertEquals(
"Listener didn't receive expected no. of messages",
--- 160,177 ----
session.rollback();
!
! // loop for a maximum of 10 seconds while we wait for
! // the receiver to receive the 10 messages again
! for (int index = 0; index < 100; index ++) {
! if (listener.getMessageCount() == 20) {
! break;
! } else {
! try {
! Thread.sleep(100);
! } catch (InterruptedException ignore) {
! }
! }
! }
!
assertEquals(
"Listener didn't receive expected no. of messages",
***************
*** 195,199 ****
subscriber.setMessageListener(listener);
! Thread.currentThread().sleep(5000);
assertEquals(
--- 220,236 ----
subscriber.setMessageListener(listener);
!
! // loop for a maximum of 10 seconds while we wait for
! // the receiver to receive the 10 messages
! for (int index = 0; index < 100; index ++) {
! if (listener.getMessageCount() == 10) {
! break;
! } else {
! try {
! Thread.sleep(100);
! } catch (InterruptedException ignore) {
! }
! }
! }
assertEquals(
***************
*** 202,206 ****
session.rollback();
! Thread.currentThread().sleep(5000);
assertEquals(
--- 239,255 ----
session.rollback();
!
! // loop for a maximum of 10 seconds while we wait for
! // the receiver to receive the 10 messages again
! for (int index = 0; index < 100; index ++) {
! if (listener.getMessageCount() == 20) {
! break;
! } else {
! try {
! Thread.sleep(100);
! } catch (InterruptedException ignore) {
! }
! }
! }
assertEquals(
|
