1 #ifndef PROTON_RECEIVER_HPP 2 #define PROTON_RECEIVER_HPP 26 #include "./internal/export.hpp" 29 #include <proton/type_compat.h> 43 PN_CPP_EXTERN
receiver(pn_link_t* r);
53 PN_CPP_EXTERN
void open();
67 PN_CPP_EXTERN
void add_credit(uint32_t);
77 PN_CPP_EXTERN
void drain();
80 friend class internal::factory<
receiver>;
81 friend class receiver_iterator;
88 class receiver_iterator :
public internal::iter_base<receiver, receiver_iterator> {
89 explicit receiver_iterator(receiver r, pn_session_t* s = 0) :
90 internal::iter_base<receiver, receiver_iterator>(r), session_(s) {}
94 explicit receiver_iterator() :
95 internal::iter_base<receiver, receiver_iterator>(0), session_(0) {}
98 PN_CPP_EXTERN receiver_iterator operator++();
101 pn_session_t* session_;
103 friend class connection;
104 friend class session;
108 typedef internal::iter_range<receiver_iterator> receiver_range;
114 #endif // PROTON_RECEIVER_HPP
A named channel for sending or receiving messages.
Definition: link.hpp:41
A named channel for sending or receiving messages.
A point of origin for messages.
Definition: source.hpp:44
Options for creating a receiver.
Definition: receiver_options.hpp:56
A channel for receiving messages.
Definition: receiver.hpp:40
A destination for messages.
Definition: target.hpp:45
The main Proton namespace.
Definition: annotation_key.hpp:33
receiver()
Create an empty receiver.
Definition: receiver.hpp:48