summaryrefslogtreecommitdiff
path: root/qpid/cpp/lib/broker/RecoveryManager.h
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-03-30 15:50:07 +0000
committerGordon Sim <gsim@apache.org>2007-03-30 15:50:07 +0000
commit72bca07ee53fb9476f268133f244d55d8f53d3b9 (patch)
tree6e8400200b22188899144a025ecb1a6c5922cc7b /qpid/cpp/lib/broker/RecoveryManager.h
parent61c7761f005dacfc5938a4d4d25b7120a8e21620 (diff)
downloadqpid-python-72bca07ee53fb9476f268133f244d55d8f53d3b9.tar.gz
Refactored the MessageStore interface to restrict visibility of broker core from store implementations.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@524139 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/lib/broker/RecoveryManager.h')
-rw-r--r--qpid/cpp/lib/broker/RecoveryManager.h16
1 files changed, 8 insertions, 8 deletions
diff --git a/qpid/cpp/lib/broker/RecoveryManager.h b/qpid/cpp/lib/broker/RecoveryManager.h
index d4e4cff3fd..700bbdcf80 100644
--- a/qpid/cpp/lib/broker/RecoveryManager.h
+++ b/qpid/cpp/lib/broker/RecoveryManager.h
@@ -21,20 +21,20 @@
#ifndef _RecoveryManager_
#define _RecoveryManager_
-#include <ExchangeRegistry.h>
-#include <QueueRegistry.h>
+#include "RecoverableQueue.h"
+#include "RecoverableMessage.h"
+#include "framing/Buffer.h"
namespace qpid {
namespace broker {
class RecoveryManager{
- QueueRegistry& queues;
- ExchangeRegistry& exchanges;
public:
- RecoveryManager(QueueRegistry& queues, ExchangeRegistry& exchanges);
- ~RecoveryManager();
- Queue::shared_ptr recoverQueue(const std::string& name);
- Exchange::shared_ptr recoverExchange(const std::string& name, const std::string& type);
+ virtual ~RecoveryManager(){}
+ virtual void recoverExchange(framing::Buffer& buffer) = 0;
+ virtual RecoverableQueue::shared_ptr recoverQueue(framing::Buffer& buffer) = 0;
+ virtual RecoverableMessage::shared_ptr recoverMessage(framing::Buffer& buffer) = 0;
+ virtual void recoveryComplete() = 0;
};