#include <Cluster.h>
Inherits qpid::cluster::Cpg::Handler, and qpid::management::Manageable.
Public Types | |
typedef boost::intrusive_ptr < Connection > | ConnectionPtr |
typedef std::vector < ConnectionPtr > | Connections |
Public Member Functions | |
Cluster (const std::string &name, const Url &url, broker::Broker &) | |
Join a cluster. | |
bool | insert (const ConnectionPtr &) |
void | erase (ConnectionId) |
void | mcastControl (const framing::AMQBody &controlBody, const ConnectionId &, uint32_t id) |
void | mcastBuffer (const char *, size_t, const ConnectionId &, uint32_t id) |
void | mcast (const Event &e) |
std::vector< Url > | getUrls () const |
boost::shared_ptr < FailoverExchange > | getFailoverExchange () const |
void | leave () |
void | dumpInDone (const ClusterMap &) |
MemberId | getId () const |
broker::Broker & | getBroker () const |
Friends | |
std::ostream & | operator<< (std::ostream &, const Cluster &) |
Definition at line 53 of file Cluster.h.
qpid::cluster::Cluster::Cluster | ( | const std::string & | name, | |
const Url & | url, | |||
broker::Broker & | ||||
) |
Join a cluster.
name | of the cluster. | |
url | of this broker, sent to the cluster. |