#include <Connection.h>
Public Member Functions | |
Connection (Cluster &, sys::ConnectionOutputHandler &out, const std::string &id, MemberId, bool catchUp) | |
Local connection, use this in ConnectionId. | |
Connection (Cluster &, sys::ConnectionOutputHandler &out, const std::string &id, ConnectionId) | |
Shadow connection. | |
ConnectionId | getId () const |
broker::Connection & | getBrokerConnection () |
bool | isLocal () const |
True for connections from direct clients of local broker. | |
bool | isShadow () const |
True for connections that are shadowing remote broker connections. | |
bool | isCatchUp () const |
True if the connection is in "catch-up" mode: building initial broker state. | |
bool | isDumped () const |
True if the connection is a completed shared dump connection. | |
Cluster & | getCluster () |
void | received (framing::AMQFrame &) |
void | closed () |
bool | doOutput () |
bool | hasOutput () |
void | idleOut () |
void | idleIn () |
size_t | decode (const char *buffer, size_t size) |
void | deliverBuffer (framing::Buffer &) |
void | delivered (framing::AMQFrame &) |
void | sessionState (const SequenceNumber &replayStart, const SequenceNumber &sendCommandPoint, const SequenceSet &sentIncomplete, const SequenceNumber &expected, const SequenceNumber &received, const SequenceSet &unknownCompleted, const SequenceSet &receivedIncomplete) |
void | shadowReady (uint64_t memberId, uint64_t connectionId) |
void | membership (const framing::FieldTable &, const framing::FieldTable &) |
Friends | |
std::ostream & | operator<< (std::ostream &, const Connection &) |
Definition at line 47 of file Connection.h.
bool qpid::cluster::Connection::isCatchUp | ( | ) | const [inline] |
True if the connection is in "catch-up" mode: building initial broker state.
Definition at line 70 of file Connection.h.