diff options
| -rw-r--r-- | cpp/src/qpid/broker/PersistableMessage.h | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/PersistableMessage.h b/cpp/src/qpid/broker/PersistableMessage.h index 17bf774377..ae96d3ab32 100644 --- a/cpp/src/qpid/broker/PersistableMessage.h +++ b/cpp/src/qpid/broker/PersistableMessage.h @@ -65,6 +65,9 @@ class PersistableMessage : public Persistable */ int asyncDequeueCounter; + void enqueueAsync(); + void dequeueAsync(); + bool contentReleased; syncList synclist; @@ -78,6 +81,7 @@ class PersistableMessage : public Persistable MessageStore* store; + public: typedef boost::shared_ptr<PersistableMessage> shared_ptr; @@ -101,7 +105,6 @@ class PersistableMessage : public Persistable QPID_BROKER_EXTERN void enqueueAsync(PersistableQueue::shared_ptr queue, MessageStore* _store); - QPID_BROKER_EXTERN void enqueueAsync(); QPID_BROKER_EXTERN bool isDequeueComplete(); @@ -110,8 +113,6 @@ class PersistableMessage : public Persistable QPID_BROKER_EXTERN void dequeueAsync(PersistableQueue::shared_ptr queue, MessageStore* _store); - QPID_BROKER_EXTERN void dequeueAsync(); - bool isStoredOnQueue(PersistableQueue::shared_ptr queue); void addToSyncList(PersistableQueue::shared_ptr queue, MessageStore* _store); |