diff options
Diffstat (limited to 'cpp/src/qpid/cluster/Connection.h')
-rw-r--r-- | cpp/src/qpid/cluster/Connection.h | 15 |
1 files changed, 12 insertions, 3 deletions
diff --git a/cpp/src/qpid/cluster/Connection.h b/cpp/src/qpid/cluster/Connection.h index 9f75d3dae3..331ac33ab0 100644 --- a/cpp/src/qpid/cluster/Connection.h +++ b/cpp/src/qpid/cluster/Connection.h @@ -40,6 +40,13 @@ namespace qpid { namespace framing { class AMQFrame; } +namespace broker { +class SemanticState; +class QueuedMessage; +class TxBuffer; +class TxAccept; +} + namespace cluster { class Cluster; @@ -117,15 +124,17 @@ class Connection : bool windowing); void queuePosition(const std::string&, const framing::SequenceNumber&); - - private: - bool catcUp; + private: bool checkUnsupported(const framing::AMQBody& body); void deliverClose(); void deliverDoOutput(uint32_t requested); void sendDoOutput(); + broker::SessionState& sessionState(); + broker::SemanticState& semanticState(); + broker::QueuedMessage getDumpMessage(); + static NoOpConnectionOutputHandler discardHandler; Cluster& cluster; |