From 89ae6edf669364f29332ff71d3e380b12e16f636 Mon Sep 17 00:00:00 2001
From: Alex Rudyy <orudyy@apache.org>
Date: Thu, 2 Oct 2014 16:17:51 +0000
Subject: QPID-6126: Add checks to allow operations with configured objects in
 ERRORED state

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1629011 13f79535-47bb-0310-9956-ffa450edef68
---
 .../model/adapter/FileSystemPreferencesProviderImpl.java   | 14 +++-----------
 .../qpid/server/virtualhost/AbstractVirtualHost.java       |  8 ++++----
 .../server/virtualhostnode/AbstractVirtualHostNode.java    |  7 ++++++-
 3 files changed, 13 insertions(+), 16 deletions(-)

(limited to 'qpid/java/broker-core/src')

diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileSystemPreferencesProviderImpl.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileSystemPreferencesProviderImpl.java
index 60be3592f8..e3ded3006d 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileSystemPreferencesProviderImpl.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/FileSystemPreferencesProviderImpl.java
@@ -112,21 +112,13 @@ public class FileSystemPreferencesProviderImpl
         }
     }
 
-    @Override
-    protected void onCreate()
-    {
-        super.validateOnCreate();
-        File storeFile  = new File(_path);
-        if (!storeFile.exists() )
-        {
-            new FileSystemPreferencesStore(storeFile).createIfNotExist();
-        }
-    }
-
     @Override
     protected void onOpen()
     {
         FileSystemPreferencesStore store = new FileSystemPreferencesStore(new File(_path));
+
+        // we need to check and create file if it does not exist every time on open
+        store.createIfNotExist();
         store.open();
         _store = store;
         _open = true;
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
index 26ce6aca4c..ff6ae19373 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
@@ -699,11 +699,11 @@ public abstract class AbstractVirtualHost<X extends AbstractVirtualHost<X>> exte
             {
                 _logger.error("Failed to close message store", e);
             }
-        }
 
-        if (!(_virtualHostNode.getConfigurationStore() instanceof MessageStoreProvider))
-        {
-            getEventLogger().message(getMessageStoreLogSubject(), MessageStoreMessages.CLOSED());
+            if (!(_virtualHostNode.getConfigurationStore() instanceof MessageStoreProvider))
+            {
+                getEventLogger().message(getMessageStoreLogSubject(), MessageStoreMessages.CLOSED());
+            }
         }
     }
 
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/AbstractVirtualHostNode.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/AbstractVirtualHostNode.java
index 1b363890dc..aea07e3ed3 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/AbstractVirtualHostNode.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/AbstractVirtualHostNode.java
@@ -176,7 +176,11 @@ public abstract class AbstractVirtualHostNode<X extends AbstractVirtualHostNode<
         deleteVirtualHostIfExists();
         close();
         deleted();
-        getConfigurationStore().onDelete(this);
+        DurableConfigurationStore configurationStore = getConfigurationStore();
+        if (configurationStore != null)
+        {
+            configurationStore.onDelete(this);
+        }
     }
 
     protected void deleteVirtualHostIfExists()
@@ -211,6 +215,7 @@ public abstract class AbstractVirtualHostNode<X extends AbstractVirtualHostNode<
     @Override
     protected void postResolve()
     {
+        super.postResolve();
         DurableConfigurationStore store = getConfigurationStore();
         if (store == null)
         {
-- 
cgit v1.2.1