From f268adad32730d29b8c6115db98294b2ccdf0d73 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?P=C3=A4r=20Dahlman?= Date: Sun, 11 Mar 2018 11:49:32 +0100 Subject: [PATCH] Revert "Making use of PooledChannelMiddleware instead of ChannelCreationMiddleware for get Operations" This reverts commit 5f07cdbef79940cb037ea656e7fbc1b04d6ebf2b. --- .../Middleware/AckableResultMiddleware.cs | 2 +- src/RawRabbit.Operations.Get/Middleware/BasicGetMiddleware.cs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/RawRabbit.Operations.Get/Middleware/AckableResultMiddleware.cs b/src/RawRabbit.Operations.Get/Middleware/AckableResultMiddleware.cs index ec7359e8..928e294c 100644 --- a/src/RawRabbit.Operations.Get/Middleware/AckableResultMiddleware.cs +++ b/src/RawRabbit.Operations.Get/Middleware/AckableResultMiddleware.cs @@ -33,7 +33,7 @@ public class AckableResultMiddleware : Pipe.Middleware.Middleware public AckableResultMiddleware(AckableResultOptions 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 index 852db5f2..702c7496 100644 --- 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;