diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/store/ConfigurationRecoveryHandler.java')
-rwxr-xr-x | qpid/java/broker/src/main/java/org/apache/qpid/server/store/ConfigurationRecoveryHandler.java | 21 |
1 files changed, 3 insertions, 18 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/store/ConfigurationRecoveryHandler.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/store/ConfigurationRecoveryHandler.java index ab7ef3f55b..2a4aed5373 100755 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/store/ConfigurationRecoveryHandler.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/store/ConfigurationRecoveryHandler.java @@ -28,25 +28,10 @@ import java.util.UUID; public interface ConfigurationRecoveryHandler { - ExchangeRecoveryHandler begin(MessageStore store); + void beginConfigurationRecovery(DurableConfigurationStore store); - public static interface ExchangeRecoveryHandler - { - void exchange(UUID id, String exchangeName, String type, boolean autoDelete); - QueueRecoveryHandler completeExchangeRecovery(); - } + void configuredObject(UUID id, String type, Map<String, Object> attributes); - public static interface QueueRecoveryHandler - { - void queue(UUID id, String queueName, String owner, boolean exclusive, FieldTable arguments, UUID alternateExchangeId); - BindingRecoveryHandler completeQueueRecovery(); - } - - - public static interface BindingRecoveryHandler - { - void binding(UUID bindingId, UUID exchangeId, UUID queueId, String bindingName, ByteBuffer buf); - void completeBindingRecovery(); - } + void completeConfigurationRecovery(); } |