Merge pull request #783 from rabbitmq/internalize-consumer-work-service

Public API cleanup, round 3

Author: lukebakken

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

@@ -321,7 +321,5 @@ public interface IConnection : INetworkConnection, IDisposable
         /// Handle incoming Connection.Unblocked methods.
         /// </summary>
         void HandleConnectionUnblocked();
-
-        ConsumerWorkService ConsumerWorkService { get; }
     }
 }

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

@@ -5,7 +5,7 @@
 
 namespace RabbitMQ.Client.Impl
 {
-    public class ConsumerWorkService
+    class ConsumerWorkService
     {
         private readonly ConcurrentDictionary<IModel, WorkPool> _workPools = new ConcurrentDictionary<IModel, WorkPool>();
 

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

@@ -40,6 +40,7 @@
 
 using System;
 using System.Collections.Generic;
+using RabbitMQ.Client.Framing.Impl;
 
 namespace RabbitMQ.Client.Impl
 {
@@ -63,7 +64,7 @@ interface ISession
         /// <summary>
         /// Gets the connection.
         /// </summary>
-        IConnection Connection { get; }
+        Connection Connection { get; }
 
         /// <summary>
         /// Gets a value indicating whether this session is open.

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

@@ -102,11 +102,6 @@ public bool IsOpen
             get { return CloseReason == null; }
         }
 
-        IConnection ISession.Connection
-        {
-            get { return Connection; }
-        }
-
         public virtual void OnCommandReceived(Command cmd)
         {
             CommandReceived?.Invoke(this, cmd);

projects/client/Unit/src/unit/APIApproval.Approve.approved.txt

@@ -267,7 +267,6 @@ namespace RabbitMQ.Client
         System.Collections.Generic.IDictionary<string, object> ClientProperties { get; }
         string ClientProvidedName { get; }
         RabbitMQ.Client.ShutdownEventArgs CloseReason { get; }
-        RabbitMQ.Client.Impl.ConsumerWorkService ConsumerWorkService { get; }
         RabbitMQ.Client.AmqpTcpEndpoint Endpoint { get; }
         uint FrameMax { get; }
         System.TimeSpan Heartbeat { get; }
@@ -782,16 +781,6 @@ namespace RabbitMQ.Client.Exceptions
         public object Offender { get; }
     }
 }
-namespace RabbitMQ.Client.Impl
-{
-    public class ConsumerWorkService
-    {
-        public ConsumerWorkService() { }
-        public void AddWork(RabbitMQ.Client.IModel model, System.Action fn) { }
-        public void StopWork() { }
-        public void StopWork(RabbitMQ.Client.IModel model) { }
-    }
-}
 namespace RabbitMQ.Client.Logging
 {
     [System.Diagnostics.Tracing.EventSource(Name="rabbitmq-dotnet-client")]