QPID-4339: simple paged queue implementation

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1477236 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 7 insertions, 9 deletions

diff --git a/cpp/src/qpid/broker/RecoveryManagerImpl.cpp b/cpp/src/qpid/broker/RecoveryManagerImpl.cpp
index ab89a46a46..df1c88d183 100644
--- a/cpp/src/qpid/broker/RecoveryManagerImpl.cpp
+++ b/cpp/src/qpid/broker/RecoveryManagerImpl.cpp
@@ -118,15 +118,8 @@ RecoverableQueue::shared_ptr RecoveryManagerImpl::recoverQueue(framing::Buffer&
 
 RecoverableMessage::shared_ptr RecoveryManagerImpl::recoverMessage(framing::Buffer& buffer)
 {
-    framing::Buffer sniffer(buffer.getPointer(), buffer.available());
-    RecoverableMessage::shared_ptr m = protocols.recover(sniffer);
-    if (m) {
-        return m;
-    } else {
-        boost::intrusive_ptr<qpid::broker::amqp_0_10::MessageTransfer> transfer(new qpid::broker::amqp_0_10::MessageTransfer());
-        transfer->decodeHeader(buffer);
-        return RecoverableMessage::shared_ptr(new RecoverableMessageImpl(Message(transfer, transfer)));
-    }
+    RecoverableMessage::shared_ptr m = protocols.recover(buffer);
+    return m;
 }
 
 RecoverableTransaction::shared_ptr RecoveryManagerImpl::recoverTransaction(const std::string& xid, 
@@ -191,6 +184,11 @@ void RecoverableMessageImpl::computeExpiration(const boost::intrusive_ptr<Expiry
     msg.computeExpiration(ep);
 }
 
+Message RecoverableMessageImpl::getMessage()
+{
+    return msg;
+}
+
 void RecoverableQueueImpl::recover(RecoverableMessage::shared_ptr msg)
 {
     dynamic_pointer_cast<RecoverableMessageImpl>(msg)->recover(queue);