File tree Expand file tree Collapse file tree 1 file changed +2
-5
lines changed
projects/client/RabbitMQ.Client/src/client/impl Expand file tree Collapse file tree 1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -70,10 +70,6 @@ public class Connection : IConnection
70
70
///<summary>Heartbeat frame for transmission. Reusable across connections.</summary>
71
71
public readonly Frame m_heartbeatFrame = new Frame ( Constants . FrameHeartbeat , 0 , new byte [ 0 ] ) ;
72
72
73
- ///<summary>Timeout used while waiting for AMQP handshaking to
74
- ///complete (milliseconds)</summary>
75
- public const int HandshakeTimeout = 10000 ;
76
-
77
73
public ManualResetEvent m_appContinuation = new ManualResetEvent ( false ) ;
78
74
public EventHandler < CallbackExceptionEventArgs > m_callbackException ;
79
75
@@ -1254,7 +1250,8 @@ protected void StartAndTune()
1254
1250
m_inConnectionNegotiation = true ;
1255
1251
var connectionStartCell = new BlockingCell ( ) ;
1256
1252
m_model0 . m_connectionStartCell = connectionStartCell ;
1257
- m_frameHandler . Timeout = HandshakeTimeout ;
1253
+ m_model0 . HandshakeContinuationTimeout = m_factory . HandshakeContinuationTimeout ;
1254
+ m_frameHandler . Timeout = m_factory . HandshakeContinuationTimeout . Milliseconds ;
1258
1255
m_frameHandler . SendHeader ( ) ;
1259
1256
1260
1257
var connectionStart = ( ConnectionStartDetails )
You can’t perform that action at this time.
0 commit comments