You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by cc...@apache.org on 2009/07/09 22:20:45 UTC
svn commit: r792665 -
/qpid/trunk/qpid/cpp/src/qpid/broker/PersistableMessage.h
Author: cctrieloff
Date: Thu Jul 9 20:20:45 2009
New Revision: 792665
URL: http://svn.apache.org/viewvc?rev=792665&view=rev
Log:
Move helper functions out of the public interface, as they are unsafe
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/PersistableMessage.h
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/PersistableMessage.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/PersistableMessage.h?rev=792665&r1=792664&r2=792665&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/PersistableMessage.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/PersistableMessage.h Thu Jul 9 20:20:45 2009
@@ -65,6 +65,9 @@
*/
int asyncDequeueCounter;
+ void enqueueAsync();
+ void dequeueAsync();
+
bool contentReleased;
syncList synclist;
@@ -78,6 +81,7 @@
MessageStore* store;
+
public:
typedef boost::shared_ptr<PersistableMessage> shared_ptr;
@@ -101,7 +105,6 @@
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 @@
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);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org