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/NullMessageStore.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/NullMessageStore.h')
| -rw-r--r-- | cpp/src/qpid/broker/NullMessageStore.h | 14 |
1 files changed, 8 insertions, 6 deletions
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<std::string> 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<PersistableMessage>& msg); + virtual void stage(const boost::intrusive_ptr<PersistableMessage>& msg); virtual void destroy(PersistableMessage& msg); - virtual void appendContent(boost::intrusive_ptr<const PersistableMessage>& msg, + virtual void appendContent(const boost::intrusive_ptr<const PersistableMessage>& msg, const std::string& data); virtual void loadContent(const qpid::broker::PersistableQueue& queue, - boost::intrusive_ptr<const PersistableMessage>& msg, std::string& data, + const boost::intrusive_ptr<const PersistableMessage>& msg, std::string& data, uint64_t offset, uint32_t length); - virtual void enqueue(TransactionContext* ctxt, boost::intrusive_ptr<PersistableMessage>& msg, + virtual void enqueue(TransactionContext* ctxt, + const boost::intrusive_ptr<PersistableMessage>& msg, const PersistableQueue& queue); - virtual void dequeue(TransactionContext* ctxt, boost::intrusive_ptr<PersistableMessage>& msg, + virtual void dequeue(TransactionContext* ctxt, + const boost::intrusive_ptr<PersistableMessage>& msg, const PersistableQueue& queue); virtual u_int32_t outstandingQueueAIO(const PersistableQueue& queue); virtual void flush(const qpid::broker::PersistableQueue& queue); |