添加RabbitMQ的VirtualHost参数

This commit is contained in:
eithday 2025-08-01 11:27:16 +08:00
parent 598da62aa4
commit ec03755ed1
2 changed files with 7 additions and 1 deletions

View File

@ -46,4 +46,9 @@ public sealed class RabbitMQSettings
/// 端口
/// </summary>
public int Port { get; set; }
/// <summary>
/// 虚拟主机
/// </summary>
public string VirtualHost { get; set; } = "/";
}

View File

@ -237,7 +237,8 @@ public class Startup : AppStartup
UserName = eventBusOpt.RabbitMQ.UserName,
Password = eventBusOpt.RabbitMQ.Password,
HostName = eventBusOpt.RabbitMQ.HostName,
Port = eventBusOpt.RabbitMQ.Port
Port = eventBusOpt.RabbitMQ.Port,
VirtualHost = eventBusOpt.RabbitMQ.VirtualHost,
}, "adminnet_eventsource_queue", 3000);
options.ReplaceStorerOrFallback(serviceProvider => { return rbmqEventSourceStorer; });
}