diff options
Diffstat (limited to 'cpp/lib/client/Connection.cpp')
| -rw-r--r-- | cpp/lib/client/Connection.cpp | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/cpp/lib/client/Connection.cpp b/cpp/lib/client/Connection.cpp index f7897aa4df..c00b58a4a9 100644 --- a/cpp/lib/client/Connection.cpp +++ b/cpp/lib/client/Connection.cpp @@ -35,7 +35,8 @@ Connection::Connection( bool _debug, u_int32_t _max_frame_size, qpid::framing:: channelIdCounter(0), max_frame_size(_max_frame_size), closed(true), - version(_version->getMajor(),_version->getMinor()) + version(_version->getMajor(),_version->getMinor()), + tcpNoDelay(false) { connector = new Connector(version, debug, _max_frame_size); } @@ -44,6 +45,10 @@ Connection::~Connection(){ delete connector; } +void Connection::setTcpNoDelay(bool on) { + tcpNoDelay = on; +} + void Connection::open(const std::string& _host, int _port, const std::string& uid, const std::string& pwd, const std::string& virtualhost){ host = _host; port = _port; @@ -51,7 +56,7 @@ void Connection::open(const std::string& _host, int _port, const std::string& ui connector->setTimeoutHandler(this); connector->setShutdownHandler(this); out = connector->getOutputHandler(); - connector->connect(host, port); + connector->connect(host, port, tcpNoDelay); ProtocolInitiation* header = new ProtocolInitiation(version); responses.expect(); |