diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2012-07-25 12:03:34 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2012-07-25 12:03:34 +0000 |
| commit | b435b07eb8fa9db484f85b39daaf43642dd623ca (patch) | |
| tree | c327f38fb21c75267abdb9cd338fe3778d883140 /cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h | |
| parent | 75e9139d60bc049fabf9b3b779ddd157bb5160bb (diff) | |
| download | qpid-python-b435b07eb8fa9db484f85b39daaf43642dd623ca.tar.gz | |
QPID-3858: WIP: Removed PersistableQueuedMessage again. The non-durable transactional enqueues are broken.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1365545 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h')
| -rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h b/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h index d872cfde58..dd10f8b501 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h +++ b/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h @@ -25,6 +25,7 @@ #define tests_storePerftools_asyncPerf_QueuedMessage_h_ #include "qpid/broker/AsyncStore.h" +#include "qpid/broker/EnqueueHandle.h" #include <boost/enable_shared_from_this.hpp> #include <boost/intrusive_ptr.hpp> @@ -54,6 +55,8 @@ public: virtual ~QueuedMessage(); SimpleQueue* getQueue() const; boost::intrusive_ptr<SimpleMessage> payload() const; + const qpid::broker::EnqueueHandle& enqHandle() const; + qpid::broker::EnqueueHandle& enqHandle(); // --- Transaction handling --- void prepareEnqueue(qpid::broker::TxnHandle& th); @@ -63,6 +66,7 @@ public: private: SimpleQueue* m_queue; boost::intrusive_ptr<SimpleMessage> m_msg; + qpid::broker::EnqueueHandle m_enqHandle; }; }}} // namespace tests::storePerfTools |