summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/Connection.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/cluster/Connection.h')
-rw-r--r--cpp/src/qpid/cluster/Connection.h10
1 files changed, 6 insertions, 4 deletions
diff --git a/cpp/src/qpid/cluster/Connection.h b/cpp/src/qpid/cluster/Connection.h
index c664427ea1..150c53807e 100644
--- a/cpp/src/qpid/cluster/Connection.h
+++ b/cpp/src/qpid/cluster/Connection.h
@@ -34,6 +34,8 @@
#include "qpid/framing/FrameDecoder.h"
#include "qpid/framing/SequenceNumber.h"
+#include <iosfwd>
+
namespace qpid {
namespace framing { class AMQFrame; }
@@ -59,11 +61,10 @@ class Connection :
ConnectionId getId() const { return self; }
broker::Connection& getBrokerConnection() { return connection; }
bool isLocal() const;
+ bool isShadow() const { return !isLocal(); }
/** True if the connection is in "catch-up" mode: building initial state */
bool isCatchUp() const { return catchUp; }
- bool isExCatchUp() const { return exCatchUp; }
-
Cluster& getCluster() { return cluster; }
@@ -109,6 +110,7 @@ class Connection :
Cluster& cluster;
ConnectionId self;
+ bool catchUp;
NoOpConnectionOutputHandler discardHandler;
WriteEstimate writeEstimate;
OutputInterceptor output;
@@ -116,8 +118,8 @@ class Connection :
broker::Connection connection;
framing::SequenceNumber mcastSeq;
framing::SequenceNumber deliverSeq;
- bool catchUp;
- bool exCatchUp;
+
+ friend std::ostream& operator<<(std::ostream&, const Connection&);
};
}} // namespace qpid::cluster