[AMQP 1.0] tcp-nodelay not supported yet on 1.0 connections
Fixed.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1622507 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/qpid/cpp/src/qpid/messaging/amqp/SslTransport.cpp b/qpid/cpp/src/qpid/messaging/amqp/SslTransport.cpp
index ffb64c4..e8ef2d5 100644
--- a/qpid/cpp/src/qpid/messaging/amqp/SslTransport.cpp
+++ b/qpid/cpp/src/qpid/messaging/amqp/SslTransport.cpp
@@ -63,6 +63,7 @@
SslTransport::SslTransport(TransportContext& c, boost::shared_ptr<Poller> p) : context(c), connector(0), aio(0), poller(p)
{
const ConnectionOptions* options = context.getOptions();
+ options->configureSocket(socket);
if (options->sslCertName != "") {
QPID_LOG(debug, "ssl-cert-name = " << options->sslCertName);
socket.setCertName(options->sslCertName);
diff --git a/qpid/cpp/src/qpid/messaging/amqp/TcpTransport.cpp b/qpid/cpp/src/qpid/messaging/amqp/TcpTransport.cpp
index c66f645..a919e97 100644
--- a/qpid/cpp/src/qpid/messaging/amqp/TcpTransport.cpp
+++ b/qpid/cpp/src/qpid/messaging/amqp/TcpTransport.cpp
@@ -20,6 +20,7 @@
*/
#include "TcpTransport.h"
#include "ConnectionContext.h"
+#include "qpid/messaging/ConnectionOptions.h"
#include "qpid/sys/AsynchIO.h"
#include "qpid/sys/ConnectionCodec.h"
#include "qpid/sys/Poller.h"
@@ -54,6 +55,7 @@
{
assert(!connector);
assert(!aio);
+ context.getOptions()->configureSocket(*socket);
connector = AsynchConnector::create(
*socket,
host, port,
