summaryrefslogtreecommitdiff
path: root/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationStore.java
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationStore.java')
-rwxr-xr-xqpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationStore.java18
1 files changed, 10 insertions, 8 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationStore.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationStore.java
index 9f610b0199..7d93f18906 100755
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationStore.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationStore.java
@@ -20,11 +20,12 @@
*/
package org.apache.qpid.server.store;
-import org.apache.qpid.server.model.ConfiguredObject;
-
import java.util.Map;
import java.util.UUID;
+import org.apache.qpid.server.model.ConfiguredObject;
+import org.apache.qpid.server.store.handler.ConfiguredObjectRecordHandler;
+
public interface DurableConfigurationStore
{
String STORE_TYPE = "storeType";
@@ -47,12 +48,6 @@ public interface DurableConfigurationStore
void openConfigurationStore(ConfiguredObject<?> parent, Map<String, Object> storeSettings) throws StoreException;
/**
- * Recovers configuration from the store using given recovery handler
- * @param recoveryHandler recovery handler
- */
- void recoverConfigurationStore(ConfigurationRecoveryHandler recoveryHandler) throws StoreException;
-
- /**
* Makes the specified object persistent.
*
* @param object The object to persist.
@@ -85,4 +80,11 @@ public interface DurableConfigurationStore
void closeConfigurationStore() throws StoreException;
+ /**
+ * Visit all configured object records with given handler.
+ *
+ * @param handler a handler to invoke on each configured object record
+ * @throws StoreException
+ */
+ void visitConfiguredObjectRecords(ConfiguredObjectRecordHandler handler) throws StoreException;
}