Added missing connection close/abort methods

Author: Hubert Plociniczak

src/client/api/IConnection.cs

@@ -169,6 +169,20 @@ public interface IConnection: IDisposable
         ///</remarks>
         void Close();
 
+        ///<summary>Close this connection and all its channels.</summary>
+        ///<remarks>
+        ///The method behaves in the same way as Close(), with the only
+        ///difference that the connection is closed with the given connection
+        ///close code and message. 
+        ///<para>
+        ///The close code (See under "Reply Codes" in the AMQP specification)
+        ///</para>
+        ///<para>
+        ///A message indicating the reason for closing the connection
+        ///</para>
+        ///</remarks>
+        void Close(ushort reasonCode, string reasonText);
+        
         ///<summary>Close this connection and all its channels
         ///and wait with a timeout for all the in-progress close operations
         ///to complete.
@@ -189,6 +203,23 @@ public interface IConnection: IDisposable
         ///</remarks>
         void Close(int timeout);
 
+        ///<summary>Close this connection and all its channels
+        ///and wait with a timeout for all the in-progress close operations
+        ///to complete.
+        ///</summary>
+        ///<remarks>
+        ///The method behaves in the same way as Close(int timeout), with the only
+        ///difference that the connection is closed with the given connection
+        ///close code and message.
+        ///<para>
+        ///The close code (See under "Reply Codes" in the AMQP specification)
+        ///</para>
+        ///<para>
+        ///A message indicating the reason for closing the connection
+        ///</para>
+        ///</remarks>
+        void Close(ushort reasonCode, string reasonText, int timeout);
+        
         ///<summary>Abort this connection and all its channels.</summary>
         ///<remarks>
         ///Note that all active channels, sessions, and models will be
@@ -200,10 +231,24 @@ public interface IConnection: IDisposable
         ///</remarks>
         void Abort();
 
+        ///<summary>Abort this connection and all its channels.</summary>
+        ///<remarks>
+        ///The method behaves in the same way as Abort(), with the only
+        ///difference that the connection is closed with the given connection
+        ///close code and message.
+        ///<para>
+        ///The close code (See under "Reply Codes" in the AMQP specification)
+        ///</para>
+        ///<para>
+        ///A message indicating the reason for closing the connection
+        ///</para>
+        ///</remarks>
+        void Abort(ushort reasonCode, string reasonText);
+        
         ///<summary>
         ///Abort this connection and all its channels and wait with a
         ///timeout for all the in-progress close operations to complete.
-        ///.</summary>
+        ///</summary>
         ///<remarks>
         ///This method, behaves in a similar way as method Abort() with the
         ///only difference that it explictly specifies the timeout given
@@ -217,6 +262,23 @@ public interface IConnection: IDisposable
         ///</remarks>
         void Abort(int timeout);
 
+        ///<summary>
+        ///Abort this connection and all its channels and wait with a
+        ///timeout for all the in-progress close operations to complete.
+        ///</summary>
+        ///<remarks>
+        ///The method behaves in the same way as Abort(timeout), with the only
+        ///difference that the connection is closed with the given connection
+        ///close code and message.
+        ///<para>
+        ///The close code (See under "Reply Codes" in the AMQP specification)
+        ///</para>
+        ///<para>
+        ///A message indicating the reason for closing the connection
+        ///</para>
+        ///</remarks>
+        void Abort(ushort reasonCode, string reasonText, int timeout);
+        
         ///<summary>Returns the list of ShutdownReportEntry objects that
         ///contain information about any errors reported while closing the
         ///connection in the order they appeared</summary>

src/client/impl/ConnectionBase.cs

@@ -353,35 +353,48 @@ public void Close()
             Close(200, "Goodbye", Timeout.Infinite);
         }
 
+        ///<summary>API-side invocation of connection close.</summary>
+        public void Close(ushort reasonCode, string reasonText)
+        {
+            Close(reasonCode, reasonText, Timeout.Infinite);
+        }
+        
         ///<summary>API-side invocation of connection close with timeout.</summary>
         public void Close(int timeout)
         {
             Close(200, "Goodbye", timeout);
         }
-
-        public void Close(ShutdownEventArgs reason)
-        {
-            Close(reason, false, Timeout.Infinite);
-        }
 
+        ///<summary>API-side invocation of connection close with timeout.</summary>
         public void Close(ushort reasonCode, string reasonText, int timeout)
         {
             Close(new ShutdownEventArgs(ShutdownInitiator.Application, reasonCode, reasonText), false, timeout);
         }
-        
+
+        public void Close(ShutdownEventArgs reason)
+        {
+            Close(reason, false, Timeout.Infinite);
+        }        
 
         ///<summary>API-side invocation of connection abort.</summary>
         public void Abort()
         {
             Abort(Timeout.Infinite);
         }
+
+        ///<summary>API-side invocation of connection abort.</summary>
+        public void Abort(ushort reasonCode, string reasonText)
+        {
+            Abort(reasonCode, reasonText, Timeout.Infinite);
+        }
 
         ///<summary>API-side invocation of connection abort with timeout.</summary>
         public void Abort(int timeout)
         {
             Abort(200, "Connection close forced", timeout);
         }
 
+        ///<summary>API-side invocation of connection abort with timeout.</summary>
         public void Abort(ushort reasonCode, string reasonText, int timeout)
         {
             Abort(reasonCode, reasonText, ShutdownInitiator.Application, timeout);