diff options
| author | Alan Conway <aconway@apache.org> | 2008-06-23 19:43:49 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2008-06-23 19:43:49 +0000 |
| commit | 3dca4bc8a413df51da579ee7c2f8273eeac2888a (patch) | |
| tree | 50f88f5e63ff3c2760339fc0bee0e752df548c0f /cpp/src/qpid/broker/MessageStoreModule.h | |
| parent | 26e408705ff28f1c185bac333a76e38b6b900063 (diff) | |
| download | qpid-python-3dca4bc8a413df51da579ee7c2f8273eeac2888a.tar.gz | |
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
Diffstat (limited to 'cpp/src/qpid/broker/MessageStoreModule.h')
| -rw-r--r-- | cpp/src/qpid/broker/MessageStoreModule.h | 18 |
1 files changed, 10 insertions, 8 deletions
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<TransactionContext> begin(); std::auto_ptr<TPCTransactionContext> 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<PersistableMessage>& msg); + void stage(const boost::intrusive_ptr<PersistableMessage>& msg); void destroy(PersistableMessage& msg); - void appendContent(boost::intrusive_ptr<const PersistableMessage>& msg, const std::string& data); + void appendContent(const boost::intrusive_ptr<const PersistableMessage>& msg, const std::string& data); void loadContent(const qpid::broker::PersistableQueue& queue, - boost::intrusive_ptr<const PersistableMessage>& msg, std::string& data, - uint64_t offset, uint32_t length); + const boost::intrusive_ptr<const PersistableMessage>& msg, std::string& data, + uint64_t offset, uint32_t length); - void enqueue(TransactionContext* ctxt, boost::intrusive_ptr<PersistableMessage>& msg, + void enqueue(TransactionContext* ctxt, + const boost::intrusive_ptr<PersistableMessage>& msg, const PersistableQueue& queue); - void dequeue(TransactionContext* ctxt, boost::intrusive_ptr<PersistableMessage>& msg, + void dequeue(TransactionContext* ctxt, + const boost::intrusive_ptr<PersistableMessage>& msg, const PersistableQueue& queue); u_int32_t outstandingQueueAIO(const PersistableQueue& queue); void flush(const qpid::broker::PersistableQueue& queue); |
