29 lines
757 B
C#
29 lines
757 B
C#
using RabbitMQ.Client;
|
|
|
|
public static class RabbitMqConnectionFactory
|
|
{
|
|
public static ConnectionFactory Create(RabbitMqOptions o, bool dispatchConsumersAsync = false)
|
|
{
|
|
var factory = new ConnectionFactory
|
|
{
|
|
HostName = o.Host,
|
|
Port = o.Port,
|
|
UserName = o.Username,
|
|
Password = o.Password,
|
|
VirtualHost = o.VirtualHost,
|
|
DispatchConsumersAsync = dispatchConsumersAsync,
|
|
};
|
|
|
|
if (o.UseSsl)
|
|
{
|
|
factory.Ssl = new SslOption
|
|
{
|
|
Enabled = true,
|
|
ServerName = o.Host,
|
|
};
|
|
}
|
|
|
|
return factory;
|
|
}
|
|
}
|