diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2012-07-16 13:54:11 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2012-07-16 13:54:11 +0000 |
| commit | a804510d81ade0594a75b5c9b8765cafcc233245 (patch) | |
| tree | 8c6be643564b6d8c88619d17de7150c98a314781 /cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h | |
| parent | 1ab07197127e990da2c765ea0ffa5fd8ca47b7b6 (diff) | |
| download | qpid-python-a804510d81ade0594a75b5c9b8765cafcc233245.tar.gz | |
QPID-3858: Refactor to tidy up several class design issues
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1362039 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 | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h b/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h index 12c8e4da08..7d4e5bbbe4 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h +++ b/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h @@ -24,8 +24,9 @@ #ifndef tests_storePerftools_asyncPerf_QueuedMessage_h_ #define tests_storePerftools_asyncPerf_QueuedMessage_h_ -#include "qpid/broker/EnqueueHandle.h" +#include "qpid/broker/AsyncStore.h" +#include <boost/enable_shared_from_this.hpp> #include <boost/intrusive_ptr.hpp> namespace qpid { @@ -42,19 +43,17 @@ namespace asyncPerf { class SimpleMessage; class SimpleQueue; -class QueuedMessage +class QueuedMessage : public boost::enable_shared_from_this<QueuedMessage> { public: QueuedMessage(); QueuedMessage(SimpleQueue* q, boost::intrusive_ptr<SimpleMessage> msg); QueuedMessage(const QueuedMessage& qm); - ~QueuedMessage(); - QueuedMessage& operator=(const QueuedMessage& rhs); + QueuedMessage(QueuedMessage* const qm); + 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); @@ -64,7 +63,6 @@ public: private: SimpleQueue* m_queue; boost::intrusive_ptr<SimpleMessage> m_msg; - qpid::broker::EnqueueHandle m_enqHandle; }; }}} // namespace tests::storePerfTools |