From 3dca4bc8a413df51da579ee7c2f8273eeac2888a Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Mon, 23 Jun 2008 19:43:49 +0000 Subject: Const-correctness fixes in MessageStore.h git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@670718 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/NullMessageStore.h | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) (limited to 'cpp/src/qpid/broker/NullMessageStore.h') diff --git a/cpp/src/qpid/broker/NullMessageStore.h b/cpp/src/qpid/broker/NullMessageStore.h index f06e749ebb..b537c05b5d 100644 --- a/cpp/src/qpid/broker/NullMessageStore.h +++ b/cpp/src/qpid/broker/NullMessageStore.h @@ -38,7 +38,7 @@ class NullMessageStore : public MessageStore std::set prepared; const bool warn; uint64_t nextPersistenceId; -public: + public: NullMessageStore(bool warn = false); virtual bool init(const Options* options); @@ -61,16 +61,18 @@ public: virtual void create(const PersistableConfig& config); virtual void destroy(const PersistableConfig& config); virtual void recover(RecoveryManager& queues); - virtual void stage(boost::intrusive_ptr& msg); + virtual void stage(const boost::intrusive_ptr& msg); virtual void destroy(PersistableMessage& msg); - virtual void appendContent(boost::intrusive_ptr& msg, + virtual void appendContent(const boost::intrusive_ptr& msg, const std::string& data); virtual void loadContent(const qpid::broker::PersistableQueue& queue, - boost::intrusive_ptr& msg, std::string& data, + const boost::intrusive_ptr& msg, std::string& data, uint64_t offset, uint32_t length); - virtual void enqueue(TransactionContext* ctxt, boost::intrusive_ptr& msg, + virtual void enqueue(TransactionContext* ctxt, + const boost::intrusive_ptr& msg, const PersistableQueue& queue); - virtual void dequeue(TransactionContext* ctxt, boost::intrusive_ptr& msg, + virtual void dequeue(TransactionContext* ctxt, + const boost::intrusive_ptr& msg, const PersistableQueue& queue); virtual u_int32_t outstandingQueueAIO(const PersistableQueue& queue); virtual void flush(const qpid::broker::PersistableQueue& queue); -- cgit v1.2.1