Revert "Making use of PooledChannelMiddleware instead of ChannelCreat…

…ionMiddleware for get Operations" This reverts commit 5f07cdb.
pardahlman · Mar 11, 2018 · f268ada · f268ada
1 parent bd43ade
commit f268ada
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/RawRabbit.Operations.Get/Middleware/AckableResultMiddleware.cs b/src/RawRabbit.Operations.Get/Middleware/AckableResultMiddleware.cs
@@ -33,7 +33,7 @@ public class AckableResultMiddleware<TResult> : Pipe.Middleware.Middleware
 		public AckableResultMiddleware(AckableResultOptions<TResult> options = null)
 		{
 			GetResultFunc = options?.ContentFunc;
-			ChannelFunc = options?.ChannelFunc ?? (context => context.GetTransientChannel());
+			ChannelFunc = options?.ChannelFunc ?? (context => context.GetChannel());
 			PostExecutionAction = options?.PostExecutionAction;
 			DeliveryTagFunc = options?.DeliveryTagFunc;
 		}

diff --git a/src/RawRabbit.Operations.Get/Middleware/BasicGetMiddleware.cs b/src/RawRabbit.Operations.Get/Middleware/BasicGetMiddleware.cs
@@ -23,7 +23,7 @@ public class BasicGetMiddleware : Pipe.Middleware.Middleware
 
 		public BasicGetMiddleware(BasicGetOptions options = null)
 		{
-			ChannelFunc = options?.ChannelFunc ?? (context => context.GetTransientChannel());
+			ChannelFunc = options?.ChannelFunc ?? (context => context.GetChannel());
 			QueueNameFunc = options?.QueueNameFunc ?? (context => context.GetGetConfiguration()?.QueueName);
 			AutoAckFunc = options?.AutoAckFunc ?? (context => context.GetGetConfiguration()?.AutoAck ?? false);
 			PostExecutionAction = options?.PostExecutionAction;