From ca78f792bb1d381c85a8e64d1768c7abe7516f70 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Thu, 5 Apr 2007 11:48:05 +0000 Subject: * Further (minor) changes to the interface between store and broker. * TxBuffer now uses shared_ptr to TxOps (removed DeletingTxOp) * Queue now persists the field table of settings git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@525801 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/broker/RecoveryManagerImpl.cpp | 12 ++++++++++++ 1 file changed, 12 insertions(+) (limited to 'qpid/cpp/src/broker/RecoveryManagerImpl.cpp') diff --git a/qpid/cpp/src/broker/RecoveryManagerImpl.cpp b/qpid/cpp/src/broker/RecoveryManagerImpl.cpp index 7c04ec9916..f82399f95c 100644 --- a/qpid/cpp/src/broker/RecoveryManagerImpl.cpp +++ b/qpid/cpp/src/broker/RecoveryManagerImpl.cpp @@ -45,6 +45,7 @@ public: RecoverableMessageImpl(Message::shared_ptr& _msg, uint64_t _stagingThreshold) : msg(_msg), stagingThreshold(_stagingThreshold) {} ~RecoverableMessageImpl() {}; + void setPersistenceId(uint64_t id); bool loadContent(uint64_t available); void decodeContent(framing::Buffer& buffer); void recover(Queue::shared_ptr queue); @@ -56,6 +57,7 @@ class RecoverableQueueImpl : public RecoverableQueue public: RecoverableQueueImpl(Queue::shared_ptr& _queue) : queue(_queue) {} ~RecoverableQueueImpl() {}; + void setPersistenceId(uint64_t id); void recover(RecoverableMessage::shared_ptr msg); }; @@ -125,7 +127,17 @@ void RecoverableMessageImpl::recover(Queue::shared_ptr queue) queue->recover(msg); } +void RecoverableMessageImpl::setPersistenceId(uint64_t id) +{ + msg->setPersistenceId(id); +} + void RecoverableQueueImpl::recover(RecoverableMessage::shared_ptr msg) { dynamic_pointer_cast(msg)->recover(queue); } + +void RecoverableQueueImpl::setPersistenceId(uint64_t id) +{ + queue->setPersistenceId(id); +} -- cgit v1.2.1