public RabbitMQService()

in extension/WebJobs.Extensions.RabbitMQ/Services/RabbitMQService.cs [12:29]


    public RabbitMQService(string connectionString, bool disableCertificateValidation)
    {
        var connectionFactory = new ConnectionFactory
        {
            Uri = new Uri(connectionString),

            // Required to use async consumer. See: https://www.rabbitmq.com/dotnet-api-guide.html#consuming-async.
            DispatchConsumersAsync = true,
        };

        if (disableCertificateValidation && connectionFactory.Ssl.Enabled)
        {
            connectionFactory.Ssl.AcceptablePolicyErrors |= SslPolicyErrors.RemoteCertificateChainErrors;
        }

        this.Model = connectionFactory.CreateConnection().CreateModel();
        this.PublishBatchLock = new object();
    }