1 #ifndef PROTON_RECEIVER_HPP 2 #define PROTON_RECEIVER_HPP 26 #include "./internal/export.hpp" 29 #include <proton/type_compat.h> 40 PN_CPP_EXTERN
receiver(pn_link_t* r);
50 PN_CPP_EXTERN
void open();
56 PN_CPP_EXTERN
class source source() const;
59 PN_CPP_EXTERN
class target target() const;
64 PN_CPP_EXTERN
void add_credit(uint32_t);
74 PN_CPP_EXTERN
void drain();
77 friend class internal::factory<receiver>;
78 friend class receiver_iterator;
86 class receiver_iterator :
public internal::iter_base<receiver, receiver_iterator> {
87 explicit receiver_iterator(receiver r, pn_session_t* s = 0) :
88 internal::iter_base<receiver, receiver_iterator>(r), session_(s) {}
92 explicit receiver_iterator() :
93 internal::iter_base<receiver, receiver_iterator>(0), session_(0) {}
96 PN_CPP_EXTERN receiver_iterator operator++();
99 pn_session_t* session_;
106 typedef internal::iter_range<receiver_iterator> receiver_range;
112 #endif // PROTON_RECEIVER_HPP A named channel for sending or receiving messages.
Definition: link.hpp:38
A connection to a remote AMQP peer.
Definition: connection.hpp:40
A point of origin for messages.
Definition: source.hpp:41
A container of senders and receivers.
Definition: session.hpp:38
Options for creating a receiver.
Definition: receiver_options.hpp:52
A channel for receiving messages.
Definition: receiver.hpp:37
A destination for messages.
Definition: target.hpp:42
The main Proton namespace.
Definition: annotation_key.hpp:30
receiver()
Create an empty receiver.
Definition: receiver.hpp:45
Experimental - A thread-safe object wrapper.
Definition: fwd.hpp:65