Rabbit MQ Prefetch Configuration On IMessageService RegisterHandler

[malinowskie]

Can someone provide an example of how to set the prefetch setting in the Rabbit MQ client? I found this thread and can verify the PR has indeed made this setting configurable. I am using version 5.5, but I am unable to configure the prefetch. Is there a unit test or an example that can be provided?

RabbitMQ Prefetch count

Hi @mythz, We are running a bunch of webjobs in Azure using RabbitMQ without a http host. We were hoping that each message on the queue would be picked up by a webjob and processed. What I’ve found is that ServiceStack sets the prefetch count to 20. Would you be willing to make this configurable (or accept a PR that makes it configurable)? Thanks, Deon

[mythz]

The PrefetchCount property @DeonHeyns added was added to the RabbitMqProducer class which you can modify by casting either the IMessageProducer or IMessageQueueClient clients to RabbitMqProducer where you can set the property directly, e.g:

using (var mqProducer = mqFactory.CreateMessageProducer())
{
    var rabbitMqProducer = (RabbitMqProducer) mqProducer;
    rabbitMqProducer.PrefetchCount = 10;
}

using (var mqClient = mqFactory.CreateMessageQueueClient())
{
    var rabbitMqProducer = (RabbitMqProducer) mqClient;
    rabbitMqProducer.PrefetchCount = 10;
}

[malinowskie]

Is there anyway to set this when consuming from a handler?

[mythz]

Not sure if by handler you mean modifying the MQ Client used to process RabbitMqServer messages, but I’ve just added a MqQueueClientFilter and MqProducerFilter in this commit which will let you modify all MQ Clients retrieved from the message factory, which you can configure with:

new RabbitMqServer(....) {
    MqQueueClientFilter = client => client.PrefetchCount = 10
}

This change is available from v5.5.1 that’s now available on MyGet.