summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/LocalQueue.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/client/LocalQueue.h')
-rw-r--r--cpp/src/qpid/client/LocalQueue.h18
1 files changed, 4 insertions, 14 deletions
diff --git a/cpp/src/qpid/client/LocalQueue.h b/cpp/src/qpid/client/LocalQueue.h
index f81065ef3c..9fe72762c3 100644
--- a/cpp/src/qpid/client/LocalQueue.h
+++ b/cpp/src/qpid/client/LocalQueue.h
@@ -23,8 +23,8 @@
*/
#include "qpid/client/Message.h"
+#include "qpid/client/Subscription.h"
#include "qpid/client/Demux.h"
-#include "qpid/client/AckPolicy.h"
#include "qpid/sys/Time.h"
namespace qpid {
@@ -38,17 +38,14 @@ namespace client {
*
* \ingroup clientapi
*/
-class LocalQueue
-{
+class LocalQueue {
public:
/** Create a local queue. Subscribe the local queue to a remote broker
* queue with a SubscriptionManager.
*
* LocalQueue is an alternative to implementing a MessageListener.
- *
- *@param ackPolicy Policy for acknowledging messages. @see AckPolicy.
*/
- LocalQueue(AckPolicy ackPolicy=AckPolicy());
+ LocalQueue();
~LocalQueue();
@@ -74,16 +71,9 @@ class LocalQueue
/** Number of messages on the local queue */
size_t size() const;
- /** Set the message acknowledgement policy. @see AckPolicy. */
- void setAckPolicy(AckPolicy);
-
- /** Get the message acknowledgement policy. @see AckPolicy. */
- AckPolicy& getAckPolicy();
-
private:
- Session session;
Demux::QueuePtr queue;
- AckPolicy autoAck;
+ Subscription subscription;
friend class SubscriptionManager;
};