Author: chirino
Date: Sat Dec 31 08:48:55 2005
New Revision: 360323
URL: http://svn.apache.org/viewcvs?rev=360323&view=rev
Log:
use a tighter wait() based on the remaining time
Modified:
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java
Modified:
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java?rev=360323&r1=360322&r2=360323&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/MessageIdList.java
Sat Dec 31 08:48:55 2005
@@ -125,11 +125,11 @@
break;
}
long duration = System.currentTimeMillis() - start;
- if (duration > maximumDuration ) {
+ if (duration >= maximumDuration ) {
break;
}
synchronized (semaphore) {
- semaphore.wait(4000);
+ semaphore.wait(maximumDuration-duration);
}
}
catch (InterruptedException e) {
