activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r391096 - in /incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store: QuickJournalRecoveryBrokerTest.java QuickJournalXARecoveryBrokerTest.java
Date Mon, 03 Apr 2006 18:00:09 GMT
Author: jstrachan
Date: Mon Apr  3 11:00:07 2006
New Revision: 391096

URL: http://svn.apache.org/viewcvs?rev=391096&view=rev
Log:
allow any implementation of PersistenceAdapterFactory to be used

Modified:
    incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalRecoveryBrokerTest.java
    incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalXARecoveryBrokerTest.java

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalRecoveryBrokerTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalRecoveryBrokerTest.java?rev=391096&r1=391095&r2=391096&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalRecoveryBrokerTest.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalRecoveryBrokerTest.java
Mon Apr  3 11:00:07 2006
@@ -20,6 +20,7 @@
 
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.RecoveryBrokerTest;
+import org.apache.activemq.store.DefaultPersistenceAdapterFactory;
 
 /**
  * Used to verify that recovery works correctly against 
@@ -31,13 +32,15 @@
     protected BrokerService createBroker() throws Exception {
         BrokerService service = new BrokerService();
         service.setDeleteAllMessagesOnStartup(true);
-        service.getPersistenceFactory().setUseQuickJournal(true);
+        DefaultPersistenceAdapterFactory factory = (DefaultPersistenceAdapterFactory) service.getPersistenceFactory();
+        factory.setUseQuickJournal(true);
         return service;
     }
     
     protected BrokerService createRestartedBroker() throws Exception {
         BrokerService service = new BrokerService();
-        service.getPersistenceFactory().setUseQuickJournal(true);
+        DefaultPersistenceAdapterFactory factory = (DefaultPersistenceAdapterFactory) service.getPersistenceFactory();
+        factory.setUseQuickJournal(true);
         return service;
     }
     

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalXARecoveryBrokerTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalXARecoveryBrokerTest.java?rev=391096&r1=391095&r2=391096&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalXARecoveryBrokerTest.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalXARecoveryBrokerTest.java
Mon Apr  3 11:00:07 2006
@@ -20,6 +20,7 @@
 
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.XARecoveryBrokerTest;
+import org.apache.activemq.store.DefaultPersistenceAdapterFactory;
 
 /**
  * Used to verify that recovery works correctly against 
@@ -39,13 +40,15 @@
     protected BrokerService createBroker() throws Exception {
         BrokerService service = new BrokerService();
         service.setDeleteAllMessagesOnStartup(true);
-        service.getPersistenceFactory().setUseQuickJournal(true);
+        DefaultPersistenceAdapterFactory factory = (DefaultPersistenceAdapterFactory) service.getPersistenceFactory();
+        factory.setUseQuickJournal(true);
         return service;
     }
     
     protected BrokerService createRestartedBroker() throws Exception {
         BrokerService service = new BrokerService();
-        service.getPersistenceFactory().setUseQuickJournal(true);
+        DefaultPersistenceAdapterFactory factory = (DefaultPersistenceAdapterFactory) service.getPersistenceFactory();
+        factory.setUseQuickJournal(true);
         return service;
     }
     



Mime
View raw message