Merge pull request #850 from stebet/preserveStacktraces

Fixing rethrown exceptions to properly preserve stackframes.

Author: michaelklishin

projects/RabbitMQ.Client/client/impl/Connection.cs

@@ -310,11 +310,11 @@ public void Close(ShutdownEventArgs reason, bool abort, TimeSpan timeout)
                     // Wait for CloseOk in the MainLoop
                     _session0.Transmit(ConnectionCloseWrapper(reason.ReplyCode, reason.ReplyText));
                 }
-                catch (AlreadyClosedException ace)
+                catch (AlreadyClosedException)
                 {
                     if (!abort)
                     {
-                        throw ace;
+                        throw;
                     }
                 }
 #pragma warning disable 0168
@@ -330,7 +330,7 @@ public void Close(ShutdownEventArgs reason, bool abort, TimeSpan timeout)
                     {
                         if (!abort)
                         {
-                            throw ioe;
+                            throw;
                         }
                         else
                         {

projects/RabbitMQ.Client/client/impl/Frame.cs

@@ -42,6 +42,7 @@
 using System.Buffers;
 using System.IO;
 using System.Net.Sockets;
+using System.Runtime.ExceptionServices;
 using System.Runtime.InteropServices;
 using RabbitMQ.Client.Exceptions;
 using RabbitMQ.Client.Framing;
@@ -228,7 +229,7 @@ private static void ProcessProtocolHeader(Stream reader)
 
         internal static InboundFrame ReadFrom(Stream reader)
         {
-            int type;
+            int type = default;
 
             try
             {
@@ -247,9 +248,10 @@ internal static InboundFrame ReadFrom(Stream reader)
                     !(ioe.InnerException is SocketException) ||
                     ((SocketException)ioe.InnerException).SocketErrorCode != SocketError.TimedOut)
                 {
-                    throw ioe;
+                    throw;
                 }
-                throw ioe.InnerException;
+
+                ExceptionDispatchInfo.Capture(ioe.InnerException).Throw();
             }
 
             if (type == 'A')

projects/RabbitMQ.Client/client/impl/SocketFrameHandler.cs

@@ -291,10 +291,10 @@ private ITcpClient ConnectUsingAddressFamily(AmqpTcpEndpoint endpoint,
                 ConnectOrFail(socket, endpoint, timeout);
                 return socket;
             }
-            catch (ConnectFailureException e)
+            catch (ConnectFailureException)
             {
                 socket.Dispose();
-                throw e;
+                throw;
             }
         }
 

projects/Unit/Fixtures.cs

@@ -499,7 +499,7 @@ private Process ExecRabbitMqCtlUsingDocker(string args, string dockerMachineName
             catch (Exception e)
             {
                 ReportExecFailure("rabbitmqctl", args, e.Message);
-                throw e;
+                throw;
             }
         }
 
@@ -556,7 +556,7 @@ internal Process ExecCommand(string ctl, string args, string changeDirTo)
             catch (Exception e)
             {
                 ReportExecFailure(cmd, args, e.Message);
-                throw e;
+                throw;
             }
         }