#include <IncomingMessage.h>
Collaboration diagram for qpid::client::IncomingMessage:
Public Member Functions | ||||
void | openReference (const std::string &name) | |||
Add a reference. | ||||
void | appendReference (const std::string &name, const std::string &data) | |||
Get a reference. | ||||
Message & | createMessage (const std::string &destination, const std::string &reference) | |||
Create a message to destination associated with reference
| ||||
Reference & | getReference (const std::string &name) | |||
Get a reference. | ||||
void | closeReference (const std::string &name) | |||
Close a reference and deliver all its messages. | ||||
void | addDestination (std::string name, Destination &) | |||
Add a destination. | ||||
void | removeDestination (std::string name) | |||
Remove a destination. | ||||
Destination & | getDestination (const std::string &name) | |||
Get a destination. | ||||
Classes | ||||
class | Destination | |||
Interface to a destination for messages. More... | ||||
struct | Reference | |||
Accumulate data associated with a set of messages. More... | ||||
class | WaitableDestination | |||
A destination that a thread can wait on till a message arrives. More... |
Uses reference and destination concepts from 0-9 Messsage class.
Basic messages use special destination and reference names to indicate get-ok, return etc. messages.
void qpid::client::IncomingMessage::addDestination | ( | std::string | name, | |
Destination & | ||||
) |
void qpid::client::IncomingMessage::appendReference | ( | const std::string & | name, | |
const std::string & | data | |||
) |
Get a reference.
Throws if not already open.
void qpid::client::IncomingMessage::closeReference | ( | const std::string & | name | ) |
Close a reference and deliver all its messages.
Throws if not open or a message has an invalid destination.
Destination& qpid::client::IncomingMessage::getDestination | ( | const std::string & | name | ) |
Get a destination.
Throws if does not exist
Reference& qpid::client::IncomingMessage::getReference | ( | const std::string & | name | ) |
Get a reference.
if | non-existent. |
void qpid::client::IncomingMessage::openReference | ( | const std::string & | name | ) |
Add a reference.
Throws if already open.
void qpid::client::IncomingMessage::removeDestination | ( | std::string | name | ) |
Remove a destination.
Throws if does not exist