activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r478262 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
Date Wed, 22 Nov 2006 18:06:25 GMT
Author: rajdavies
Date: Wed Nov 22 10:06:24 2006
New Revision: 478262

URL: http://svn.apache.org/viewvc?view=rev&rev=478262
Log:
Ensure clear all containers - not just active ones

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java?view=diff&rev=478262&r1=478261&r2=478262
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
Wed Nov 22 10:06:24 2006
@@ -118,14 +118,17 @@
 
     public synchronized void clear() throws IOException{
         initialize();
-        for(Iterator i=maps.values().iterator();i.hasNext();){
-            BaseContainerImpl container=(BaseContainerImpl)i.next();
+        for (Iterator i = mapsContainer.getKeys().iterator(); i.hasNext();) {
+            ContainerId id = (ContainerId)i.next();
+            MapContainer container = getMapContainer(id.getKey(),id.getDataContainerName());
             container.clear();
         }
-        for(Iterator i=lists.values().iterator();i.hasNext();){
-            BaseContainerImpl container=(BaseContainerImpl)i.next();
+        for (Iterator i = listsContainer.getKeys().iterator(); i.hasNext();) {
+            ContainerId id = (ContainerId)i.next();
+            ListContainer container = getListContainer(id.getKey(),id.getDataContainerName());
             container.clear();
         }
+        
     }
 
     public synchronized boolean delete() throws IOException{



Mime
View raw message