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();
}