Prevent socket error when shutting down

Emile Joubert · Emile Joubert · commit fbcbda6ca384 · 2010-10-26T11:24:31.000+01:00
diff --git a/projects/client/RabbitMQ.Client/src/client/impl/IFrameHandler.cs b/projects/client/RabbitMQ.Client/src/client/impl/IFrameHandler.cs
@@ -61,7 +61,7 @@ public interface IFrameHandler
         AmqpTcpEndpoint Endpoint { get; }
 
         ///<summary>Socket read timeout, in milliseconds. Zero signals "infinity".</summary>
-        int Timeout { get; set; }
+        int Timeout { set; }
 
         void SendHeader();
 
diff --git a/projects/client/RabbitMQ.Client/src/client/impl/SocketFrameHandler_0_9.cs b/projects/client/RabbitMQ.Client/src/client/impl/SocketFrameHandler_0_9.cs
@@ -104,13 +104,12 @@ public AmqpTcpEndpoint Endpoint
 
         public int Timeout
         {
-            get
-            {
-                return m_socket.ReceiveTimeout;
-            }
-            set
-            {
-                m_socket.ReceiveTimeout = value;
+            set
+            {
+                if (m_socket.Connected)
+                {
+                    m_socket.ReceiveTimeout = value;
+                }
             }
         }
 

Original file line number	Diff line number	Diff line change
`@@ -104,13 +104,12 @@ public AmqpTcpEndpoint Endpoint`
`104`	`104`
`105`	`105`	`public int Timeout`
`106`	`106`	`{`
`107`		`- get`
`108`		`- {`
`109`		`- return m_socket.ReceiveTimeout;`
`110`		`- }`
`111`		`- set`
`112`		`- {`
`113`		`- m_socket.ReceiveTimeout = value;`
	`107`	`+ set`
	`108`	`+ {`
	`109`	`+ if (m_socket.Connected)`
	`110`	`+ {`
	`111`	`+ m_socket.ReceiveTimeout = value;`
	`112`	`+ }`
`114`	`113`	`}`
`115`	`114`	`}`
`116`	`115`