Merge pull request #122 from mikehadlow/master

Added GetChannelsAsync overload that takes the connection.

Author: mikehadlow

Source/EasyNetQ.Management.Client.IntegrationTests/ManagementClientTests.cs

@@ -141,7 +141,23 @@ public async Task Should_get_channels()
 			}
 		}
 
-		[Fact]
+        [Fact]
+        public async Task Should_get_channels_per_connection()
+        {
+            var connections = await managementClient.GetConnectionsAsync().ConfigureAwait(false);
+            foreach (var connection in connections)
+            {
+                Console.Out.WriteLine("connection.Name = {0}", connection.Name);
+                var channels = await managementClient.GetChannelsAsync(connection).ConfigureAwait(false);
+
+                foreach (var channel in channels)
+                {
+                    Console.Out.WriteLine("\tchannel.Name = {0}", channel.Name);
+                }
+            }
+        }
+
+        [Fact]
 		public async Task Should_get_exchanges()
 		{
 			var exchanges = await managementClient.GetExchangesAsync().ConfigureAwait(false);

Source/EasyNetQ.Management.Client/IManagementClient.cs

@@ -65,6 +65,14 @@ Task<Overview> GetOverviewAsync(
         /// <returns></returns>
         Task<IEnumerable<Channel>> GetChannelsAsync(CancellationToken cancellationToken = default(CancellationToken));
 
+        /// <summary>
+        /// A list of all open channels for the given connection.
+        /// </summary>
+        /// <param name="connection"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<Channel>> GetChannelsAsync(Connection connection, CancellationToken cancellationToken = default(CancellationToken));
+
         /// <summary>
         /// Gets the channel. This returns more detail, including consumers than the GetChannels method.
         /// </summary>

Source/EasyNetQ.Management.Client/ManagementClient.cs

@@ -173,6 +173,13 @@ public Task<IEnumerable<Channel>> GetChannelsAsync(
             return GetAsync<IEnumerable<Channel>>("channels", cancellationToken);
         }
 
+        public Task<IEnumerable<Channel>> GetChannelsAsync(
+            Connection connection,
+            CancellationToken cancellationToken = default(CancellationToken))
+        {
+            return GetAsync<IEnumerable<Channel>>($"connections/{connection.Name}/channels", cancellationToken);
+        }
+
         public Task<Channel> GetChannelAsync(string channelName, GetRatesCriteria ratesCriteria = null,
             CancellationToken cancellationToken = default(CancellationToken))
         {