We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 04bdd6e commit ad0ab76Copy full SHA for ad0ab76
src/client/impl/SocketFrameHandler_0_9.cs
@@ -81,7 +81,14 @@ public SocketFrameHandler_0_9(AmqpTcpEndpoint endpoint)
81
// disable Nagle's algorithm, for more consistently low latency
82
m_socket.NoDelay = true;
83
84
- Stream netstream = m_socket.GetStream();
+ Stream netstream;
85
+
86
+ if(!endpoint.SslIsEnabled) {
87
+ netstream = m_socket.GetStream();
88
+ } else {
89
+ netstream = SslHelper.TcpUpgrade(m_socket.GetStream(), endpoint.SslOption);
90
+ }
91
92
m_reader = new NetworkBinaryReader(netstream);
93
m_writer = new NetworkBinaryWriter(netstream);
94
}
0 commit comments