svn commit: r833497 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java

[gtully]

Author: gtully
Date: Fri Nov  6 17:54:15 2009
New Revision: 833497

URL: http://svn.apache.org/viewvc?rev=833497&view=rev
Log:
wait a little longer on slow machines where recovery can take a while

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java?rev=833497&r1=833496&r2=833497&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java Fri Nov  6 17:54:15 2009
@@ -48,8 +48,6 @@
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.command.ActiveMQTopic;
-import org.apache.activemq.store.PersistenceAdapter;
-import org.apache.activemq.store.amq.AMQPersistenceAdapter;
 import org.apache.activemq.store.amq.AMQPersistenceAdapterFactory;
 import org.apache.activemq.util.Wait;
 import org.apache.commons.logging.Log;
@@ -78,8 +76,7 @@
     private class SimpleTopicSubscriber implements MessageListener, ExceptionListener {
 
         private TopicConnection topicConnection = null;
-        private String clientId;
-
+        
         public SimpleTopicSubscriber(String connectionURL, String clientId, String topicName) {
 
             ActiveMQConnectionFactory topicConnectionFactory = null;
@@ -98,7 +95,6 @@
 
                 topicSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
                 topicSubscriber = topicSession.createDurableSubscriber(topic, (clientId));
-                this.clientId = clientId;
                 topicSubscriber.setMessageListener(this);
 
             } catch (JMSException e) {
@@ -281,7 +277,7 @@
             public boolean isSatisified() throws Exception {
                 return receivedCount.get() > numMessages;
             }
-        });
+        }, 60*1000);
         assertTrue("got some messages: " + receivedCount.get(), receivedCount.get() > numMessages);
         assertTrue("no exceptions, but: " + exceptions, exceptions.isEmpty());
     }