#include <Cpg.h>
Inherits qpid::sys::IOHandle.
Public Member Functions | |
Cpg (Handler &) | |
Open a CPG handle. | |
~Cpg () | |
Destructor calls shutdown if not already calledx. | |
void | shutdown () |
Disconnect from CPG. | |
void | dispatch (cpg_dispatch_t type) |
Dispatch CPG events. | |
void | dispatchOne () |
void | dispatchAll () |
void | dispatchBlocking () |
void | join (const Name &group) |
void | leave (const Name &group) |
void | mcast (const Name &group, const iovec *iov, int iovLen) |
cpg_handle_t | getHandle () const |
MemberId | self () const |
int | getFd () |
Static Public Member Functions | |
static std::string | str (const cpg_name &n) |
Manages a single CPG handle, initialized in ctor, finialzed in destructor. On error all functions throw Cpg::Exception.
Definition at line 49 of file Cpg.h.
qpid::cluster::Cpg::Cpg | ( | Handler & | ) |
Open a CPG handle.
handler | for CPG events. |
qpid::cluster::Cpg::~Cpg | ( | ) |
Destructor calls shutdown if not already calledx.
void qpid::cluster::Cpg::dispatch | ( | cpg_dispatch_t | type | ) | [inline] |