Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AMQPersistenceAdapter is now used instead of the QuickPersistenceAdapter 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515065 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-03-06 10:51:19 +00:00
parent d262dfd4a9
commit 4bef5e3599
4 changed files with 17 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/JPAPersistenceAdapter.java
View File

@ -17,6 +17,7 @@
*/ */
package org.apache.activemq.store.jpa; package org.apache.activemq.store.jpa;
import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.util.HashSet; import java.util.HashSet;
import java.util.List; import java.util.List;
@ -244,4 +245,13 @@ public class JPAPersistenceAdapter implements PersistenceAdapter {
this.wireFormat = wireFormat; this.wireFormat = wireFormat;
} }
public void checkpoint(boolean sync) throws IOException{
}
public void setBrokerName(String brokerName){
}
public void setDirectory(File dir){
}
} }

8
activemq-jpa-store/src/test/java/org/apache/activemq/broker/store/QuickJPAStoreRecoveryBrokerTest.java
View File

@ -18,13 +18,11 @@
package org.apache.activemq.broker.store; package org.apache.activemq.broker.store;
import java.util.Properties; import java.util.Properties;
import junit.framework.Test; import junit.framework.Test;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.broker.RecoveryBrokerTest; import org.apache.activemq.broker.RecoveryBrokerTest;
import org.apache.activemq.store.amq.AMQPersistenceAdapter;
import org.apache.activemq.store.jpa.JPAReferenceStoreAdapter; import org.apache.activemq.store.jpa.JPAReferenceStoreAdapter;
import org.apache.activemq.store.quick.QuickPersistenceAdapter;
/** /**
* Used to verify that recovery works correctly against * Used to verify that recovery works correctly against
@ -36,7 +34,7 @@ public class QuickJPAStoreRecoveryBrokerTest extends RecoveryBrokerTest {
protected BrokerService createBroker() throws Exception { protected BrokerService createBroker() throws Exception {
BrokerService service = new BrokerService(); BrokerService service = new BrokerService();
service.setDeleteAllMessagesOnStartup(true); service.setDeleteAllMessagesOnStartup(true);
QuickPersistenceAdapter pa = new QuickPersistenceAdapter(); AMQPersistenceAdapter pa = new AMQPersistenceAdapter();
JPAReferenceStoreAdapter rfa = new JPAReferenceStoreAdapter(); JPAReferenceStoreAdapter rfa = new JPAReferenceStoreAdapter();
Properties props = new Properties(); Properties props = new Properties();
@ -53,7 +51,7 @@ public class QuickJPAStoreRecoveryBrokerTest extends RecoveryBrokerTest {
protected BrokerService createRestartedBroker() throws Exception { protected BrokerService createRestartedBroker() throws Exception {
BrokerService service = new BrokerService(); BrokerService service = new BrokerService();
QuickPersistenceAdapter pa = new QuickPersistenceAdapter(); AMQPersistenceAdapter pa = new AMQPersistenceAdapter();
JPAReferenceStoreAdapter rfa = new JPAReferenceStoreAdapter(); JPAReferenceStoreAdapter rfa = new JPAReferenceStoreAdapter();
Properties props = new Properties(); Properties props = new Properties();

8
activemq-jpa-store/src/test/java/org/apache/activemq/broker/store/QuickJPAStoreXARecoveryBrokerTest.java
View File

@ -18,13 +18,11 @@
package org.apache.activemq.broker.store; package org.apache.activemq.broker.store;
import java.util.Properties; import java.util.Properties;
import junit.framework.Test; import junit.framework.Test;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.broker.XARecoveryBrokerTest; import org.apache.activemq.broker.XARecoveryBrokerTest;
import org.apache.activemq.store.amq.AMQPersistenceAdapter;
import org.apache.activemq.store.jpa.JPAReferenceStoreAdapter; import org.apache.activemq.store.jpa.JPAReferenceStoreAdapter;
import org.apache.activemq.store.quick.QuickPersistenceAdapter;
/** /**
* Used to verify that recovery works correctly against * Used to verify that recovery works correctly against
@ -44,7 +42,7 @@ public class QuickJPAStoreXARecoveryBrokerTest extends XARecoveryBrokerTest {
protected BrokerService createBroker() throws Exception { protected BrokerService createBroker() throws Exception {
BrokerService service = new BrokerService(); BrokerService service = new BrokerService();
service.setDeleteAllMessagesOnStartup(true); service.setDeleteAllMessagesOnStartup(true);
QuickPersistenceAdapter pa = new QuickPersistenceAdapter(); AMQPersistenceAdapter pa = new AMQPersistenceAdapter();
JPAReferenceStoreAdapter rfa = new JPAReferenceStoreAdapter(); JPAReferenceStoreAdapter rfa = new JPAReferenceStoreAdapter();
Properties props = new Properties(); Properties props = new Properties();
@ -61,7 +59,7 @@ public class QuickJPAStoreXARecoveryBrokerTest extends XARecoveryBrokerTest {
protected BrokerService createRestartedBroker() throws Exception { protected BrokerService createRestartedBroker() throws Exception {
BrokerService service = new BrokerService(); BrokerService service = new BrokerService();
QuickPersistenceAdapter pa = new QuickPersistenceAdapter(); AMQPersistenceAdapter pa = new AMQPersistenceAdapter();
JPAReferenceStoreAdapter rfa = new JPAReferenceStoreAdapter(); JPAReferenceStoreAdapter rfa = new JPAReferenceStoreAdapter();
Properties props = new Properties(); Properties props = new Properties();

2
activemq-jpa-store/src/test/resources/org/apache/activemq/broker/store/quickjpabroker.xml
View File

@ -29,7 +29,7 @@
</transportConnectors> </transportConnectors>
<persistenceAdapter> <persistenceAdapter>
<quickPersistenceAdapter directory="${basedir}/target/activemq-data/quick-broker.db" referenceStoreAdapter="#jpa"/> <amqPersistenceAdapter referenceStoreAdapter="#jpa"/>
</persistenceAdapter> </persistenceAdapter>
</broker> </broker>