Support being able to test against the LevelDB store too.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1407523 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2012-11-09 16:25:08 +00:00
parent 4702739db2
commit aa36bba9a0
1 changed files with 5 additions and 1 deletions

View File

@ -40,6 +40,7 @@ import org.apache.activemq.store.PersistenceAdapter;
import org.apache.activemq.store.amq.AMQPersistenceAdapter; import org.apache.activemq.store.amq.AMQPersistenceAdapter;
import org.apache.activemq.store.jdbc.JDBCPersistenceAdapter; import org.apache.activemq.store.jdbc.JDBCPersistenceAdapter;
import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter; import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
import org.apache.activemq.store.leveldb.LevelDBPersistenceAdapter;
import org.apache.activemq.store.memory.MemoryPersistenceAdapter; import org.apache.activemq.store.memory.MemoryPersistenceAdapter;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -174,7 +175,7 @@ public abstract class TestSupport extends CombinationTestSupport {
regionBroker.getTopicRegion().getDestinationMap(); regionBroker.getTopicRegion().getDestinationMap();
} }
public static enum PersistenceAdapterChoice {KahaDB, AMQ, JDBC, MEM }; public static enum PersistenceAdapterChoice {LevelDB, KahaDB, AMQ, JDBC, MEM };
public PersistenceAdapter setDefaultPersistenceAdapter(BrokerService broker) throws IOException { public PersistenceAdapter setDefaultPersistenceAdapter(BrokerService broker) throws IOException {
return setPersistenceAdapter(broker, defaultPersistenceAdapter); return setPersistenceAdapter(broker, defaultPersistenceAdapter);
@ -192,6 +193,9 @@ public abstract class TestSupport extends CombinationTestSupport {
case KahaDB: case KahaDB:
adapter = new KahaDBPersistenceAdapter(); adapter = new KahaDBPersistenceAdapter();
break; break;
case LevelDB:
adapter = new LevelDBPersistenceAdapter();
break;
case MEM: case MEM:
adapter = new MemoryPersistenceAdapter(); adapter = new MemoryPersistenceAdapter();
break; break;