activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1071737 - in /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover: FailoverTransactionTest.java FailoverTransportBrokerTest.java
Date Thu, 17 Feb 2011 18:27:54 GMT
Author: gtully
Date: Thu Feb 17 18:27:54 2011
New Revision: 1071737

URL: http://svn.apache.org/viewvc?rev=1071737&view=rev
Log:
don't use MEM store for transaction recovery tests

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransportBrokerTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java?rev=1071737&r1=1071736&r2=1071737&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java
Thu Feb 17 18:27:54 2011
@@ -123,7 +123,8 @@ public class FailoverTransactionTest ext
     }
 
     public void initCombosForTestFailoverCommitReplyLost() {
-        addCombinationValues("defaultPersistenceAdapter", PersistenceAdapterChoice.values());
+        addCombinationValues("defaultPersistenceAdapter",
+                new Object[]{PersistenceAdapterChoice.KahaDB, PersistenceAdapterChoice.AMQ,
PersistenceAdapterChoice.JDBC});
     }
 
     public void testFailoverCommitReplyLost() throws Exception {

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransportBrokerTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransportBrokerTest.java?rev=1071737&r1=1071736&r2=1071737&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransportBrokerTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverTransportBrokerTest.java
Thu Feb 17 18:27:54 2011
@@ -145,9 +145,10 @@ public class FailoverTransportBrokerTest
         });
         c.start();
         int count = 0;
-        while(count++ < 5 && info[0] == null) {
+        while(count++ < 20 && info[0] == null) {
             TimeUnit.SECONDS.sleep(1);
         }
+        assertNotNull("got a valid brokerInfo after 20 secs", info[0]);
         assertNull("no peer brokers present", info[0].getPeerBrokerInfos());
     }
 



Mime
View raw message