ConnectionFactory now implements internal IAsyncConnectionFactory

Implementing an internal interface is a non-breaking change from an API perspective

Author: danielmarbach

projects/client/RabbitMQ.Client/src/client/api/ConnectionFactory.cs

@@ -98,7 +98,7 @@ namespace RabbitMQ.Client
     ///"amqp://foo/" (note the trailling slash) also represent the
     ///default virtual host.  The latter issue means that virtual
     ///hosts with an empty name are not addressable. </para></remarks>
-    public class ConnectionFactory : ConnectionFactoryBase, IConnectionFactory
+    public class ConnectionFactory : ConnectionFactoryBase, IAsyncConnectionFactory
     {
         /// <summary>
         /// Default value for the desired maximum channel number, with zero meaning unlimited (value: 0).
@@ -481,7 +481,7 @@ public IConnection CreateConnection(IEndpointResolver endpointResolver, String c
                 throw new BrokerUnreachableException(e);
             }
 
-            return DispatchConsumersAsync ? new AsyncConnectionDecorator(conn) : conn;
+            return conn;
         }
 
         public IFrameHandler CreateFrameHandler()

projects/client/RabbitMQ.Client/src/client/api/IAsyncConnectionFactory.cs

@@ -0,0 +1,7 @@
+namespace RabbitMQ.Client
+{
+    internal interface IAsyncConnectionFactory : IConnectionFactory
+    {
+        bool DispatchConsumersAsync { get; set; }
+    }
+}