#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.
1.5.6