(#279) Use named channel pool for response

pardahlman · Oct 8, 2017 · d7b2a4f · d7b2a4f
1 parent c140a46
commit d7b2a4f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/RawRabbit.Operations.Respond/Core/RespondKey.cs b/src/RawRabbit.Operations.Respond/Core/RespondKey.cs
@@ -8,5 +8,6 @@ public static class RespondKey
 		public const string IncomingMessageType = "IncommingMessageType";
 		public const string PublicationAddress = "PublicationAddress";
 		public const string Configuration = "Configuration";
+		public const string ChannelPoolName = "ChannelPool:Respond";
 	}
 }
diff --git a/src/RawRabbit.Operations.Respond/RespondExtension.cs b/src/RawRabbit.Operations.Respond/RespondExtension.cs
@@ -42,7 +42,7 @@ public static class RespondExtension
 			.Use<StageMarkerMiddleware>(StageMarkerOptions.For(RespondStage.ResponseSerialized))
 			.Use<ReplyToExtractionMiddleware>()
 			.Use<StageMarkerMiddleware>(StageMarkerOptions.For(RespondStage.ReplyToExtracted))
-			.Use<TransientChannelMiddleware>()
+			.Use<PooledChannelMiddleware>(new PooledChannelOptions{ PoolNameFunc = c => RespondKey.ChannelPoolName})
 			.Use<StageMarkerMiddleware>(StageMarkerOptions.For(RespondStage.RespondChannelCreated))
 			.Use<BasicPublishMiddleware>(new BasicPublishOptions
 			{