Merge bug23839 (Add capabilities to client connection)

Author: Simon MacMullen

projects/client/RabbitMQ.Client/src/client/impl/AbstractProtocolBase.cs

@@ -42,6 +42,8 @@
 using RabbitMQ.Client.Impl;
 using RabbitMQ.Util;
 
+using System.Collections;
+
 namespace RabbitMQ.Client.Impl {
     public abstract class AbstractProtocolBase: IProtocol {
         public abstract int MajorVersion { get; }
@@ -50,6 +52,8 @@ public abstract class AbstractProtocolBase: IProtocol {
         public abstract string ApiName { get; }
         public abstract int DefaultPort { get; }
 
+        public IDictionary Capabilities = new Hashtable();
+
         public abstract IFrameHandler CreateFrameHandler(AmqpTcpEndpoint endpoint);
         public abstract IConnection CreateConnection(ConnectionFactory factory,
                                                      bool insist,
@@ -74,20 +78,20 @@ public abstract void CreateChannelClose(ushort reasonCode,
                                                    out Command request,
                                                    out int replyClassId,
                                                    out int replyMethodId);
-                                                   
+
         ///<summary>Used in the quiescing session to determine if the command
         ///is allowed to be sent.</summary>
-        public abstract bool CanSendWhileClosed(Command cmd); 
+        public abstract bool CanSendWhileClosed(Command cmd);
 
         public AmqpVersion Version {
             get {
                 return new AmqpVersion(MajorVersion, MinorVersion);
             }
         }
 
-	    public override string ToString() {
-	        return Version.ToString();
-	    }
+        public override string ToString() {
+            return Version.ToString();
+        }
 
         public override bool Equals(object obj) {
             return (GetType() == obj.GetType());

projects/client/RabbitMQ.Client/src/client/impl/ConnectionBase.cs

@@ -984,6 +984,7 @@ protected void StartAndTune()
             }
 
             m_clientProperties = new Hashtable(m_factory.ClientProperties);
+            m_clientProperties["capabilities"] = Protocol.Capabilities;
 
             // FIXME: parse out locales properly!
             ConnectionTuneDetails connectionTune = default(ConnectionTuneDetails);

projects/client/RabbitMQ.Client/src/client/impl/v0_9_1/ProtocolBase.cs

@@ -42,9 +42,17 @@
 using RabbitMQ.Client.Impl;
 using RabbitMQ.Util;
 
+using System.Collections;
+
 namespace RabbitMQ.Client.Framing.Impl.v0_9_1 {
     public abstract class ProtocolBase: AbstractProtocolBase {
 
+        public ProtocolBase() {
+            Capabilities["publisher_confirms"] = true;
+            Capabilities["exchange_exchange_bindings"] = true;
+            Capabilities["basic.nack"] = true;
+        }
+
         public override IFrameHandler CreateFrameHandler(AmqpTcpEndpoint endpoint) {
             return new SocketFrameHandler_0_9(endpoint);
         }