[rhmessaging-commits] rhmessaging commits: r2160 - store/trunk/cpp/lib.

[rhmessaging-commits at lists.jboss.org]

Author: gordonsim
Date: 2008-06-25 05:10:23 -0400 (Wed, 25 Jun 2008)
New Revision: 2160

Modified:
   store/trunk/cpp/lib/BdbMessageStore.cpp
   store/trunk/cpp/lib/BdbMessageStore.h
Log:
Made corresponding const changes to keep inline with changes to qpid trunk.



Modified: store/trunk/cpp/lib/BdbMessageStore.cpp
===================================================================
--- store/trunk/cpp/lib/BdbMessageStore.cpp	2008-06-24 20:28:59 UTC (rev 2159)
+++ store/trunk/cpp/lib/BdbMessageStore.cpp	2008-06-25 09:10:23 UTC (rev 2160)
@@ -999,7 +999,7 @@
     return peek.get_size();
 }
 
-void BdbMessageStore::appendContent(intrusive_ptr<const PersistableMessage>& msg, const std::string& data)
+void BdbMessageStore::appendContent(const intrusive_ptr<const PersistableMessage>& msg, const std::string& data)
 {
     checkInit();
     u_int64_t messageId (msg->getPersistenceId());
@@ -1029,7 +1029,7 @@
 }
 
 void BdbMessageStore::loadContent(const qpid::broker::PersistableQueue& queue,
-                                  intrusive_ptr<const PersistableMessage>& msg, std::string& data, u_int64_t offset, u_int32_t length)
+                                  const intrusive_ptr<const PersistableMessage>& msg, std::string& data, u_int64_t offset, u_int32_t length)
 {
     checkInit();
     u_int64_t realOffset = offset + sizeof(u_int32_t)/*header length*/+ msg->encodedHeaderSize();

Modified: store/trunk/cpp/lib/BdbMessageStore.h
===================================================================
--- store/trunk/cpp/lib/BdbMessageStore.h	2008-06-24 20:28:59 UTC (rev 2159)
+++ store/trunk/cpp/lib/BdbMessageStore.h	2008-06-25 09:10:23 UTC (rev 2160)
@@ -204,9 +204,9 @@
 
     void stage(const boost::intrusive_ptr<qpid::broker::PersistableMessage>& msg);
     void destroy(qpid::broker::PersistableMessage& msg);
-    void appendContent(boost::intrusive_ptr<const qpid::broker::PersistableMessage>& msg, const std::string& data);
+    void appendContent(const boost::intrusive_ptr<const qpid::broker::PersistableMessage>& msg, const std::string& data);
     void loadContent(const qpid::broker::PersistableQueue& queue,
-                     boost::intrusive_ptr<const qpid::broker::PersistableMessage>& msg, 
+                     const boost::intrusive_ptr<const qpid::broker::PersistableMessage>& msg, 
                      std::string& data, u_int64_t offset, u_int32_t length);
 
     void enqueue(qpid::broker::TransactionContext* ctxt,