Interface through which messages are received.
More...
#include <qpid/messaging/Receiver.h>
|
typedef ReceiverImpl | Impl |
|
Interface through which messages are received.
Definition at line 45 of file Receiver.h.
qpid::messaging::Receiver::Receiver |
( |
ReceiverImpl * |
impl = 0 | ) |
|
qpid::messaging::Receiver::Receiver |
( |
const Receiver & |
| ) |
|
qpid::messaging::Receiver::~Receiver |
( |
| ) |
|
void qpid::messaging::Receiver::close |
( |
| ) |
|
Retrieves a message from this Receiver's subscription or waits for up to the specified timeout for one to become available.
Unlike get(), this method will check with the server that there is no message for the subscription this receiver is serving before returning false.
- Returns
- false if there is no message available after waiting for the specified time period, or if the receiver is closed, in which case isClosed() will be true.
Retrieves a message for this Receiver's subscription or waits for up to the specified timeout for one to become available.
Unlike get(), this method will check with the server that there is no message for the subscription this receiver is serving before throwing an exception.
- Exceptions
-
NoMessageAvailable | if there is no message available after waiting for the specified timeout, or if the Receiver is closed, in which case isClose() will be true. |
Retrieves a message from this Receiver's local queue or waits for up to the specified timeout for a message to become available.
Retrieves a message from this Receiver's local queue or waits for up to the specified timeout for a message to become available.
- Exceptions
-
Address qpid::messaging::Receiver::getAddress |
( |
| ) |
const |
uint32_t qpid::messaging::Receiver::getAvailable |
( |
| ) |
|
- Returns
- the number of messages received and waiting to be fetched.
uint32_t qpid::messaging::Receiver::getCapacity |
( |
| ) |
|
- Returns
- the capacity of the Receiver. The capacity determines how many incoming messages can be held in the Receiver before being requested by a client via fetch() (or pushed to a listener).
const std::string& qpid::messaging::Receiver::getName |
( |
| ) |
const |
Session qpid::messaging::Receiver::getSession |
( |
| ) |
const |
Returns a handle to the session associated with this Receiver.
uint32_t qpid::messaging::Receiver::getUnsettled |
( |
| ) |
|
- Returns
- the number of messages received on this Receiver that have been acknowledged, but for which that acknowledgement has not yet been confirmed as processed by the server.
bool qpid::messaging::Receiver::isClosed |
( |
| ) |
const |
- Returns
- true if handle is null. It is an error to call any function on a null handle.
Definition at line 46 of file Handle.h.
- Returns
- true if handle is valid, i.e. not null.
Definition at line 43 of file Handle.h.
Conversion to bool supports idiom if (handle) { handle->...
}
Definition at line 49 of file Handle.h.
Operator ! supports idiom if (!handle) { do_if_handle_is_null(); }.
Definition at line 52 of file Handle.h.
void qpid::messaging::Receiver::setCapacity |
( |
uint32_t |
| ) |
|
Sets the capacity for the Receiver.
The capacity determines how many incoming messages can be held in the Receiver before being requested by a client via fetch() (or pushed to a listener).
The documentation for this class was generated from the following file: