1 #ifndef PROTON_SENDER_HPP 2 #define PROTON_SENDER_HPP 26 #include "./internal/export.hpp" 38 PN_CPP_EXTERN
sender(pn_link_t* s);
48 PN_CPP_EXTERN
void open();
57 PN_CPP_EXTERN
class source source() const;
60 PN_CPP_EXTERN
class target target() const;
68 PN_CPP_EXTERN
void return_credit();
71 friend class internal::factory<sender>;
72 friend class sender_iterator;
80 class sender_iterator :
public internal::iter_base<sender, sender_iterator> {
81 sender_iterator(sender snd, pn_session_t* s = 0) :
82 internal::iter_base<sender, sender_iterator>(snd), session_(s) {}
87 internal::iter_base<sender, sender_iterator>(0), session_(0) {}
89 PN_CPP_EXTERN sender_iterator operator++();
92 pn_session_t* session_;
99 typedef internal::iter_range<sender_iterator> sender_range;
105 #endif // PROTON_SENDER_HPP An AMQP message.
Definition: message.hpp:47
A channel for sending messages.
Definition: sender.hpp:35
sender()
Create an empty sender.
Definition: sender.hpp:43
Options for creating a sender.
Definition: sender_options.hpp:54
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
A tracker for a sent message.
Definition: tracker.hpp:37
A destination for messages.
Definition: target.hpp:42
The main Proton namespace.
Definition: annotation_key.hpp:30
Experimental - A thread-safe object wrapper.
Definition: fwd.hpp:65