svn commit: r503681 - in /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha: Loader.java MapContainerTest.java

[rajdavies]

Author: rajdavies
Date: Mon Feb  5 05:58:15 2007
New Revision: 503681

URL: http://svn.apache.org/viewvc?view=rev&rev=503681
Log:
use Kaha MapContainer for message storage instead of the Kaha ListContainer

Modified:
    
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/Loader.java
    
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/MapContainerTest.java

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/Loader.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/Loader.java?view=diff&rev=503681&r1=503680&r2=503681
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/Loader.java 
(original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/Loader.java 
Mon Feb  5 05:58:15 2007
@@ -53,7 +53,7 @@
             start.await();
             Marshaller keyMarshaller=new StringMarshaller();
             Marshaller valueMarshaller=new BytesMarshaller();
-            MapContainer 
container=store.getMapContainer(name,Store.DEFAULT_CONTAINER_NAME,Store.IndexType.PERSISTENT);
+            MapContainer 
container=store.getMapContainer(name,Store.DEFAULT_CONTAINER_NAME,true);
            
             container.setKeyMarshaller(keyMarshaller);
             container.setValueMarshaller(valueMarshaller);

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/MapContainerTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/MapContainerTest.java?view=diff&rev=503681&r1=503680&r2=503681
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/MapContainerTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/MapContainerTest.java
 Mon Feb  5 05:58:15 2007
@@ -177,7 +177,7 @@
         super.setUp();
         name = System.getProperty("basedir", 
".")+"/target/activemq-data/map-container.db";
         store = getStore();
-        container = 
store.getMapContainer("test","test",Store.IndexType.PERSISTENT);
+        container = store.getMapContainer("test","test",true);
         container.load();
         testMap = new HashMap();
         for (int i =0; i < COUNT; i++){