Merge branch 'release/2.8.1'
This commit is contained in:
commit
aa9e13f914
@ -820,7 +820,7 @@ namespace Tapeti.Connection
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (connectionParams.PrefetchCount > 0)
|
if (connectionParams.PrefetchCount > 0)
|
||||||
capturedPublishChannelModel.BasicQos(0, connectionParams.PrefetchCount, false);
|
capturedConsumeChannelModel.BasicQos(0, connectionParams.PrefetchCount, false);
|
||||||
|
|
||||||
capturedPublishChannelModel.ModelShutdown += (_, e) =>
|
capturedPublishChannelModel.ModelShutdown += (_, e) =>
|
||||||
{
|
{
|
||||||
|
@ -143,13 +143,13 @@ namespace Tapeti.Connection
|
|||||||
{
|
{
|
||||||
var queues = config.Bindings.GroupBy(binding => binding.QueueName);
|
var queues = config.Bindings.GroupBy(binding => binding.QueueName);
|
||||||
|
|
||||||
consumerTags.AddRange(await Task.WhenAll(queues.Select(async group =>
|
consumerTags.AddRange((await Task.WhenAll(queues.Select(async group =>
|
||||||
{
|
{
|
||||||
var queueName = group.Key;
|
var queueName = group.Key;
|
||||||
var consumer = new TapetiConsumer(cancellationToken, config, queueName, group);
|
var consumer = new TapetiConsumer(cancellationToken, config, queueName, group);
|
||||||
|
|
||||||
return await clientFactory().Consume(cancellationToken, queueName, consumer);
|
return await clientFactory().Consume(cancellationToken, queueName, consumer);
|
||||||
})));
|
}))).Where(t => t != null));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user