MT Preftech

gistfile1.txt

var busControl = Bus.Factory.CreateUsingRabbitMq(cfg => {
                cfg.UseLog4Net();
                cfg.UseApplicationInsights(_telemetryClient);
                cfg.PrefetchCount = (ushort)_settings.MessageBusPrefetchCount; // 10 in our config

                host = cfg.Host("rabbitcluster", config.VHost, h => {
                    h.UseCluster(c => prioritisedHostNames.ForEach(c.Node));
                    h.Username(_shardConfigProvider.Username);
                    h.Password(_shardConfigProvider.Password);
                    h.PublisherConfirmation = _publisherConfirms;
                });
                
                if (!string.IsNullOrEmpty(queueName)) {
                    var tempQueueName = CreateTemporaryQueueName(queueName, out id);
                    cfg.OverrideDefaultBusEndpointQueueName(tempQueueName);
                }

                if (_deployOnly) cfg.DeployTopologyOnly = true;
            });
            
            
            _connectFunc = host =>
                host.ConnectReceiveEndpoint(_queue,
                    c =>
                    {
                    // both endpointConfigurator and consumerConfigurator are null for this test
                        endpointConfigurator?.Invoke(c);
                        c.Consumer(Peregrine.Core.Ninject.Kernel, consumerConfigurator);
                    });

You aren't setting the PrefetchCount for the receive endpoint, only the bus endpoint.