1 #ifndef PROTON_RECEIVER_HPP
2 #define PROTON_RECEIVER_HPP
25 #include "./internal/export.hpp"
26 #include "./endpoint.hpp"
29 #include <proton/types.h>
33 struct pn_connection_t;
36 template <
class T>
class thread_safe;
42 PN_CPP_EXTERN
receiver(pn_link_t* r);
52 PN_CPP_EXTERN
void open();
66 PN_CPP_EXTERN
void add_credit(uint32_t);
76 PN_CPP_EXTERN
void drain();
79 friend class internal::factory<receiver>;
80 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:56
A point of origin for messages.
Definition: source.hpp:41
Options for creating a receiver.
Definition: receiver_options.hpp:62
A channel for receiving messages.
Definition: receiver.hpp:39
A destination for messages.
Definition: target.hpp:40
receiver()
Create an empty receiver.
Definition: receiver.hpp:47
Experimental - A thread-safe object wrapper.
Definition: connection.hpp:45