(#279) Use PooledChannelMiddleware in tools

pardahlman · Oct 8, 2017 · a2017ff · a2017ff
1 parent c92d649
commit a2017ff
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/RawRabbit.Operations.Tools/BasicPublishExtension.cs b/src/RawRabbit.Operations.Tools/BasicPublishExtension.cs
@@ -11,7 +11,7 @@ public static class BasicPublishExtension
 	{
 		public static readonly Action<IPipeBuilder> PublishPipe = builder => builder
 			.Use<BasicPublishConfigurationMiddleware>()
-			.Use<TransientChannelMiddleware>()
+			.Use<PooledChannelMiddleware>()
 			.Use<BasicPublishMiddleware>();
 
 		public static Task BasicPublishAsync(
@@ -44,4 +44,4 @@ public static Task BasicPublishAsync(
 			);
 		}
 	}
-}
+}
diff --git a/src/RawRabbit.Operations.Tools/DeleteExchangeExtension.cs b/src/RawRabbit.Operations.Tools/DeleteExchangeExtension.cs
@@ -22,7 +22,7 @@ public static class DeleteExchangeExtension
 				}
 				return func();
 			})
-			.Use<TransientChannelMiddleware>()
+			.Use<PooledChannelMiddleware>()
 			.Use<ExchangeDeleteMiddleware>(new ExchangeDeleteOptions
 			{
 				ExchangeNameFunc = context => context.Get<string>(ExchangeName),

diff --git a/src/RawRabbit.Operations.Tools/DeleteQueueExtension.cs b/src/RawRabbit.Operations.Tools/DeleteQueueExtension.cs
@@ -21,7 +21,7 @@ public static class DeleteQueueExtension
 				}
 				return func();
 			})
-			.Use<TransientChannelMiddleware>()
+			.Use<PooledChannelMiddleware>()
 			.Use<QueueDeleteMiddleware>(new QueueDeleteOptions
 			{
 				QueueNameFunc = context => context.Get<string>(QueueName)