00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021 #ifndef _RecoveryManagerImpl_
00022 #define _RecoveryManagerImpl_
00023
00024 #include <list>
00025 #include "ExchangeRegistry.h"
00026 #include "QueueRegistry.h"
00027 #include "RecoveryManager.h"
00028
00029 namespace qpid {
00030 namespace broker {
00031
00032 class RecoveryManagerImpl : public RecoveryManager{
00033 QueueRegistry& queues;
00034 ExchangeRegistry& exchanges;
00035 const uint64_t stagingThreshold;
00036 public:
00037 RecoveryManagerImpl(QueueRegistry& queues, ExchangeRegistry& exchanges, uint64_t stagingThreshold);
00038 ~RecoveryManagerImpl();
00039
00040 void recoverExchange(framing::Buffer& buffer);
00041 RecoverableQueue::shared_ptr recoverQueue(framing::Buffer& buffer);
00042 RecoverableMessage::shared_ptr recoverMessage(framing::Buffer& buffer);
00043 void recoveryComplete();
00044
00045 static uint8_t decodeMessageType(framing::Buffer& buffer);
00046 static void encodeMessageType(const Message& msg, framing::Buffer& buffer);
00047 static uint32_t encodedMessageTypeSize();
00048 };
00049
00050
00051 }
00052 }
00053
00054
00055 #endif