Author: cctrieloff
Date: Thu Jul 30 16:14:03 2009
New Revision: 799348
URL: http://svn.apache.org/viewvc?rev=799348&view=rev
Log:
QPID-652 -- fixed by Marco Bisioli
Modified:
qpid/trunk/qpid/cpp/src/qpid/client/Connector.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/client/Connector.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/Connector.cpp?rev=799348&r1=799347&r2=799348&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/Connector.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/Connector.cpp Thu Jul 30 16:14:03 2009
@@ -360,8 +360,10 @@
if (!initiated) {
framing::ProtocolInitiation protocolInit;
if (protocolInit.decode(in)) {
- //TODO: check the version is correct
QPID_LOG(debug, "RECV " << identifier << " INIT(" << protocolInit
<< ")");
+ if(!(protocolInit==version)){
+ throw Exception(QPID_MSG("Unsupported version: " <<
protocolInit));
+ }
}
initiated = true;
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
