#include <Cluster.h>
Public Types | |
typedef std::vector< Member > | MemberList |
Public Member Functions | |
Cluster (const std::string &name, const Url &url, broker::Broker &) | |
Join a cluster. | |
boost::intrusive_ptr < broker::SessionManager::Observer > | getObserver () |
MemberList | getMembers () const |
Get the current cluster membership. | |
size_t | size () const |
Number of members in the cluster. | |
bool | empty () const |
bool | wait (boost::function< bool(const Cluster &)> predicate, sys::Duration timeout=sys::TIME_INFINITE) const |
Wait for predicate(*this) to be true, up to timeout. | |
void | send (framing::AMQFrame &, framing::FrameHandler *) |
Send frame to the cluster. | |
Friends | |
std::ostream & | operator<< (std::ostream &, const Cluster &) |
std::ostream & | operator<< (std::ostream &, const MemberMap::value_type &) |
std::ostream & | operator<< (std::ostream &, const MemberMap &) |
Classes | |
struct | Member |
Details of a cluster member. More... |
Keeps cluster membership data.
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. |
MemberList qpid::cluster::Cluster::getMembers | ( | ) | const |
Get the current cluster membership.
size_t qpid::cluster::Cluster::size | ( | ) | const |
Number of members in the cluster.
bool qpid::cluster::Cluster::wait | ( | boost::function< bool(const Cluster &)> | predicate, | |
sys::Duration | timeout = sys::TIME_INFINITE | |||
) | const |
Wait for predicate(*this) to be true, up to timeout.