svn commit: r1155363 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ExpiredMessagesWithNoConsumerTest.java

[ta...@apache.org]

Author: tabish
Date: Tue Aug  9 13:39:23 2011
New Revision: 1155363

URL: http://svn.apache.org/viewvc?rev=1155363&view=rev
Log:
Give the wait for expiration a bit more time since a really slow disk + CPU can't seem to get it done in 30secs.  

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ExpiredMessagesWithNoConsumerTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ExpiredMessagesWithNoConsumerTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ExpiredMessagesWithNoConsumerTest.java?rev=1155363&r1=1155362&r2=1155363&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ExpiredMessagesWithNoConsumerTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ExpiredMessagesWithNoConsumerTest.java Tue Aug  9 13:39:23 2011
@@ -20,7 +20,14 @@ import java.util.concurrent.CountDownLat
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;
 
-import javax.jms.*;
+import javax.jms.Connection;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageListener;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+import javax.jms.Topic;
+import javax.jms.TopicSubscriber;
 import javax.management.ObjectName;
 
 import junit.framework.Test;
@@ -141,7 +148,7 @@ public class ExpiredMessagesWithNoConsum
 
         assertTrue("producer failed to complete within allocated time", Wait.waitFor(new Wait.Condition() {
             public boolean isSatisified() throws Exception {
-                producingThread.join(TimeUnit.SECONDS.toMillis(1000));
+                producingThread.join(TimeUnit.SECONDS.toMillis(3000));
                 return !producingThread.isAlive();
             }
         }));
@@ -154,7 +161,7 @@ public class ExpiredMessagesWithNoConsum
                         + ", size= " + view.getQueueSize());
                 return sendCount == view.getExpiredCount();
             }
-        });
+        }, Wait.MAX_WAIT_MILLIS * 5);
         LOG.info("enqueue=" + view.getEnqueueCount() + ", dequeue=" + view.getDequeueCount()
                 + ", inflight=" + view.getInFlightCount() + ", expired= " + view.getExpiredCount()
                 + ", size= " + view.getQueueSize());