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/MessageStoreModule.h | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) (limited to 'cpp/src/qpid/broker/MessageStoreModule.h') diff --git a/cpp/src/qpid/broker/MessageStoreModule.h b/cpp/src/qpid/broker/MessageStoreModule.h index f4d05e3e0d..41a76e7a50 100644 --- a/cpp/src/qpid/broker/MessageStoreModule.h +++ b/cpp/src/qpid/broker/MessageStoreModule.h @@ -38,10 +38,10 @@ namespace broker { class MessageStoreModule : public MessageStore { MessageStore* store; -public: + public: MessageStoreModule(MessageStore* store); - bool init(const Options* options); + bool init(const Options* options); std::auto_ptr begin(); std::auto_ptr begin(const std::string& xid); void prepare(TPCTransactionContext& txn); @@ -60,16 +60,18 @@ public: void create(const PersistableConfig& config); void destroy(const PersistableConfig& config); void recover(RecoveryManager& queues); - void stage(boost::intrusive_ptr& msg); + void stage(const boost::intrusive_ptr& msg); void destroy(PersistableMessage& msg); - void appendContent(boost::intrusive_ptr& msg, const std::string& data); + void appendContent(const boost::intrusive_ptr& msg, const std::string& data); void loadContent(const qpid::broker::PersistableQueue& queue, - boost::intrusive_ptr& msg, std::string& data, - uint64_t offset, uint32_t length); + const boost::intrusive_ptr& msg, std::string& data, + uint64_t offset, uint32_t length); - void enqueue(TransactionContext* ctxt, boost::intrusive_ptr& msg, + void enqueue(TransactionContext* ctxt, + const boost::intrusive_ptr& msg, const PersistableQueue& queue); - void dequeue(TransactionContext* ctxt, boost::intrusive_ptr& msg, + void dequeue(TransactionContext* ctxt, + const boost::intrusive_ptr& msg, const PersistableQueue& queue); u_int32_t outstandingQueueAIO(const PersistableQueue& queue); void flush(const qpid::broker::PersistableQueue& queue); -- cgit v1.2.1