From 3c72961e09ff4fde36c81db9628aa3f5f79db747 Mon Sep 17 00:00:00 2001
From: Robert Davies <rajdavies@apache.org>
Date: Fri, 7 Apr 2006 22:31:53 +0000
Subject: [PATCH] handle concurrent close errors

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392441 13f79535-47bb-0310-9956-ffa450edef68
---
 .../main/java/org/apache/activemq/kaha/impl/StoreImpl.java  | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/StoreImpl.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/StoreImpl.java
index a5b219a0a2..cbe4493258 100755
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/StoreImpl.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/StoreImpl.java
@@ -65,9 +65,10 @@ public class StoreImpl implements Store{
      * 
      * @see org.apache.activemq.kaha.Store#close()
      */
-    public void close() throws IOException{
+    public void close() {
         synchronized(mutex){
             if(!closed){
+                try {
                 for(Iterator i=mapContainers.values().iterator();i.hasNext();){
                     MapContainerImpl container=(MapContainerImpl) i.next();
                     container.close();
@@ -79,6 +80,9 @@ public class StoreImpl implements Store{
                 force();
                 dataFile.close();
                 closed=true;
+                }catch(IOException e){
+                    log.debug("Failed to close the store cleanly",e);
+                }
             }
         }
     }