79264860

Date: 2024-12-09 11:54:23
Score: 0.5
Natty:
Report link

As advice in comment I write down solution.

var handle = _endpointConnector.ConnectReceiveEndpoint(queueName, (bc, hc) =>
{
    hc.ConfigureConsumeTopology = false;
    hc.Consumer<MessageAConsumer>();
    ((IRabbitMqReceiveEndpointConfigurator)hc).Bind<MessageA>(s => {
        s.RoutingKey = (string)keyItem;
        s.ExchangeType = ExchangeType.Direct;
    });
    hc.ConfigureTransport(cfg =>
    {
        cfg.ConcurrentMessageLimit = 20;
        cfg.PrefetchCount = 20;
    });
});
Reasons:
  • Has code block (-0.5):
  • Self-answer (0.5):
  • Low reputation (0.5):
Posted by: Piotr