Made passing of transaction context in message store explicit (to avoid thread local storage in case this doesn't fit with new io design).

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472067 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 6 insertions, 2 deletions

diff --git a/cpp/src/qpid/broker/Queue.h b/cpp/src/qpid/broker/Queue.h
index 8473465cab..fd0bad43ff 100644
--- a/cpp/src/qpid/broker/Queue.h
+++ b/cpp/src/qpid/broker/Queue.h
@@ -58,6 +58,7 @@ namespace qpid {
             mutable qpid::sys::Monitor lock;
             int64_t lastUsed;
             Consumer* exclusive;
+            u_int64_t persistenceId;
 
             bool startDispatching();
             bool dispatch(Message::shared_ptr& msg);
@@ -106,10 +107,13 @@ namespace qpid {
             inline const string& getName() const { return name; }
             inline const bool isExclusiveOwner(const ConnectionToken* const o) const { return o == owner; }
             inline bool hasExclusiveConsumer() const { return exclusive; }
+            inline u_int64_t getPersistenceId() const { return persistenceId; }
+            inline void setPersistenceId(u_int64_t _persistenceId) { persistenceId = _persistenceId; }
+
             bool canAutoDelete() const;
 
-            void enqueue(Message::shared_ptr& msg, const string * const xid);
-            void dequeue(Message::shared_ptr& msg, const string * const xid);
+            void enqueue(TransactionContext* ctxt, Message::shared_ptr& msg, const string * const xid);
+            void dequeue(TransactionContext* ctxt, Message::shared_ptr& msg, const string * const xid);
         };
     }
 }