diff options
| author | Alan Conway <aconway@apache.org> | 2009-07-30 18:46:17 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2009-07-30 18:46:17 +0000 |
| commit | 2a2ad630c4a7afeca560977fa71759389eca42ba (patch) | |
| tree | 7f1400b40545286cb4ff586bf7aadbe72b44f0f0 /cpp/src/qpid/amqp_0_10/Connection.h | |
| parent | adc8062ac65028c1c3daf07a33b24145200d3e20 (diff) | |
| download | qpid-python-2a2ad630c4a7afeca560977fa71759389eca42ba.tar.gz | |
Set protocol versions correctly in cluster code.
Cluster code was broken by a recent checkin to validate protocol
versions. The cluster was not correctly setting the version on both
sides of a connection.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@799401 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/amqp_0_10/Connection.h')
| -rw-r--r-- | cpp/src/qpid/amqp_0_10/Connection.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/amqp_0_10/Connection.h b/cpp/src/qpid/amqp_0_10/Connection.h index 32aadff105..6fd51381fc 100644 --- a/cpp/src/qpid/amqp_0_10/Connection.h +++ b/cpp/src/qpid/amqp_0_10/Connection.h @@ -55,6 +55,7 @@ class Connection : public sys::ConnectionCodec, bool initialized; bool isClient; size_t buffered; + framing::ProtocolVersion version; public: QPID_BROKER_EXTERN Connection(sys::OutputControl&, const std::string& id, bool isClient); @@ -71,6 +72,10 @@ class Connection : public sys::ConnectionCodec, void send(framing::AMQFrame&); framing::ProtocolVersion getVersion() const; size_t getBuffered() const; + + /** Used by cluster code to set a special version on "update" connections. */ + // FIXME aconway 2009-07-30: find a cleaner mechanism for this. + void setVersion(const framing::ProtocolVersion&); }; }} // namespace qpid::amqp_0_10 |