diff options
| author | Carl C. Trieloff <cctrieloff@apache.org> | 2007-01-09 19:44:50 +0000 |
|---|---|---|
| committer | Carl C. Trieloff <cctrieloff@apache.org> | 2007-01-09 19:44:50 +0000 |
| commit | 13659cefe235ac0228749ba53e534910b9aae193 (patch) | |
| tree | 048e91f6708aa307a239ad1df65f551161a971ba /qpid/cpp/lib/client/Connector.cpp | |
| parent | 639e998c5fe03fc0a73667887af6a1828d400c0e (diff) | |
| download | qpid-python-13659cefe235ac0228749ba53e534910b9aae193.tar.gz | |
Most of remaining version changes for C++. Still need to deal with AMQFrame
defualt constructor and do some clean up here and there..
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@494540 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/lib/client/Connector.cpp')
| -rw-r--r-- | qpid/cpp/lib/client/Connector.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/qpid/cpp/lib/client/Connector.cpp b/qpid/cpp/lib/client/Connector.cpp index 2bd77c1bcd..b34e66fd94 100644 --- a/qpid/cpp/lib/client/Connector.cpp +++ b/qpid/cpp/lib/client/Connector.cpp @@ -28,10 +28,11 @@ using namespace qpid::client; using namespace qpid::framing; using qpid::QpidError; -Connector::Connector(bool _debug, u_int32_t buffer_size) : - debug(_debug), +Connector::Connector(const qpid::framing::ProtocolVersion& pVersion, bool _debug, u_int32_t buffer_size) : + debug(_debug), receive_buffer_size(buffer_size), send_buffer_size(buffer_size), + version(pVersion), closed(true), lastIn(0), lastOut(0), timeout(0), @@ -162,7 +163,7 @@ void Connector::run(){ inbuf.move(received); inbuf.flip();//position = 0, limit = total data read - AMQFrame frame; + AMQFrame frame(version); while(frame.decode(inbuf)){ if(debug) std::cout << "RECV: " << frame << std::endl; input->received(&frame); |