summaryrefslogtreecommitdiff
path: root/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
commit33d8343d134a391fa7d0a338fafad1a22ff58dc3 (patch)
tree7c8b9ef3ea62852eb38548be87f908b2892e12a2 /cpp/lib/broker/RecoveryManager.h
parent8fc571ee337add8f2c4ab1f1ebc0c4784c58e2bf (diff)
downloadqpid-python-33d8343d134a391fa7d0a338fafad1a22ff58dc3.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/qpid@524139 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/lib/broker/RecoveryManager.h')
-rw-r--r--cpp/lib/broker/RecoveryManager.h16
1 files changed, 8 insertions, 8 deletions
diff --git a/cpp/lib/broker/RecoveryManager.h b/cpp/lib/broker/RecoveryManager.h
index d4e4cff3fd..700bbdcf80 100644
--- a/cpp/lib/broker/RecoveryManager.h
+++ b/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;
};