(#224) Use channel from context if present

pardahlman · May 7, 2017 · e6a0dfa · e6a0dfa
1 parent 9d7834d
commit e6a0dfa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/RawRabbit/Pipe/Middleware/ConsumerMiddleware.cs b/src/RawRabbit/Pipe/Middleware/ConsumerMiddleware.cs
@@ -25,7 +25,7 @@ public ConsumerMiddleware(IConsumerFactory consumerFactory, ConsumerOptions opti
 		{
 			ConsumerFactory = consumerFactory;
 			ConfigFunc = options?.ConfigurationFunc ?? (context => context.GetConsumeConfiguration());
-			ConsumerFunc = options?.ConsumerFunc ?? ((factory, token, context) => factory.CreateConsumerAsync(token: token));
+			ConsumerFunc = options?.ConsumerFunc ?? ((factory, token, context) => factory.CreateConsumerAsync(context.GetChannel(), token));
 		}
 
 		public override async Task InvokeAsync(IPipeContext context, CancellationToken token = default(CancellationToken))