1 #ifndef QPID_CLIENT_SUBSCRIPTIONMANAGER_H
2 #define QPID_CLIENT_SUBSCRIPTIONMANAGER_H
38 class SubscriptionManagerImpl;
118 const std::string& queue,
120 const std::string& name=std::string());
133 const std::string& queue,
135 const std::string& name=std::string());
149 const std::string& queue,
150 const std::string& name=std::string());
162 const std::string& queue,
163 const std::string& name=std::string());
273 SubscriptionManager(SubscriptionManagerImpl*);
276 typedef SubscriptionManagerImpl Impl;
283 AutoCancel(SubscriptionManager&,
const std::string& tag);
286 SubscriptionManager& sm;
AutoCancel cancels a subscription in its destructor.
#define QPID_CLIENT_CLASS_EXTERN
Class to represent the duration between instants of time.
Settings for a subscription.
A handle to an active subscription.
AMQP 0-10 session API with keyword arguments.
A message sent to or received from the broker.
A class to help create and manage subscriptions.
Interface for objects that can be run, e.g.
Flow control works by associating a finite amount of "credit" with a subscription.
const Duration TIME_INFINITE
Value to represent an infinite timeout.
#define QPID_CLIENT_EXTERN
A handle is like a pointer: refers to an underlying implementation object.
AutoCancel(SubscriptionManager &, const std::string &tag)
Implement a subclass of MessageListener and subscribe it using the SubscriptionManager to receive mes...
A local queue to collect messages retrieved from a remote broker queue.