Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
Interface through which messages are sent. More...
#include <qpid/messaging/Sender.h>
Public Member Functions | |
Sender (SenderImpl *impl=0) | |
Sender (const Sender &) | |
~Sender () | |
Sender & | operator= (const Sender &) |
void | send (const Message &message, bool sync=false) |
Sends a message. | |
void | close () |
void | setCapacity (uint32_t) |
Sets the capacity for the sender. | |
uint32_t | getCapacity () |
Returns the capacity of the sender. | |
uint32_t | getUnsettled () |
Returns the number of sent messages pending confirmation of receipt by the broker. | |
uint32_t | getAvailable () |
Returns the number of messages for which there is available capacity. | |
const std::string & | getName () const |
Returns the name of this sender. | |
Session | getSession () const |
Returns a handle to the session associated with this sender. | |
Address | getAddress () const |
Returns an address for this sender. | |
QPID_MESSAGING_INLINE_EXTERN bool | isValid () const |
QPID_MESSAGING_INLINE_EXTERN bool | isNull () const |
QPID_MESSAGING_INLINE_EXTERN | operator bool () const |
Conversion to bool supports idiom if (handle) { handle->... | |
QPID_MESSAGING_INLINE_EXTERN bool | operator! () const |
Operator ! supports idiom if (!handle) { do_if_handle_is_null(); }. | |
void | swap (Handle< SenderImpl > &h) |
Protected Types | |
typedef SenderImpl | Impl |
Protected Attributes | |
Impl * | impl |
typedef SenderImpl qpid::messaging::Handle< SenderImpl >::Impl [protected, inherited] |
qpid::messaging::Sender::Sender | ( | SenderImpl * | impl = 0 | ) |
qpid::messaging::Sender::Sender | ( | const Sender & | ) |
void qpid::messaging::Sender::close | ( | ) |
Address qpid::messaging::Sender::getAddress | ( | ) | const |
Returns an address for this sender.
Returns the number of messages for which there is available capacity.
Returns the capacity of the sender.
const std::string& qpid::messaging::Sender::getName | ( | ) | const |
Returns the name of this sender.
Session qpid::messaging::Sender::getSession | ( | ) | const |
Returns a handle to the session associated with this sender.
Returns the number of sent messages pending confirmation of receipt by the broker.
(These are the 'in-doubt' messages).
QPID_MESSAGING_INLINE_EXTERN bool qpid::messaging::Handle< SenderImpl >::isNull | ( | ) | const [inline, inherited] |
QPID_MESSAGING_INLINE_EXTERN bool qpid::messaging::Handle< SenderImpl >::isValid | ( | ) | const [inline, inherited] |
QPID_MESSAGING_INLINE_EXTERN qpid::messaging::Handle< SenderImpl >::operator bool | ( | ) | const [inline, inherited] |
QPID_MESSAGING_INLINE_EXTERN bool qpid::messaging::Handle< SenderImpl >::operator! | ( | ) | const [inline, inherited] |
void qpid::messaging::Sender::send | ( | const Message & | message, |
bool | sync = false |
||
) |
Sends a message.
message | the message to send |
sync | if true the call will block until the server confirms receipt of the messages; if false will only block for available capacity (i.e. pending == capacity) |
Sets the capacity for the sender.
The capacity determines how many outgoing messages can be held pending confirmation of receipt by the broker.
void qpid::messaging::Handle< SenderImpl >::swap | ( | Handle< SenderImpl > & | h | ) | [inline, inherited] |
Impl* qpid::messaging::Handle< SenderImpl >::impl [protected, inherited] |