From 9fd0e37310b4b56e8718ed849078f4ad323db4fe Mon Sep 17 00:00:00 2001 From: Savorboard Date: Fri, 21 Jun 2019 11:30:06 +0800 Subject: [PATCH] Add service name to RabbitMQ connection alias name --- .../IConnectionChannelPool.Default.cs | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/DotNetCore.CAP.RabbitMQ/IConnectionChannelPool.Default.cs b/src/DotNetCore.CAP.RabbitMQ/IConnectionChannelPool.Default.cs index 35e220a..2bff115 100644 --- a/src/DotNetCore.CAP.RabbitMQ/IConnectionChannelPool.Default.cs +++ b/src/DotNetCore.CAP.RabbitMQ/IConnectionChannelPool.Default.cs @@ -4,6 +4,7 @@ using System; using System.Collections.Concurrent; using System.Diagnostics; +using System.Reflection; using System.Threading; using Microsoft.Extensions.Logging; using RabbitMQ.Client; @@ -90,6 +91,8 @@ namespace DotNetCore.CAP.RabbitMQ private static Func CreateConnection(RabbitMQOptions options) { + var serviceName = Assembly.GetEntryAssembly()?.GetName().Name.ToLower(); + var factory = new ConnectionFactory { UserName = options.UserName, @@ -97,17 +100,17 @@ namespace DotNetCore.CAP.RabbitMQ Password = options.Password, VirtualHost = options.VirtualHost }; - + if (options.HostName.Contains(",")) { options.ConnectionFactoryOptions?.Invoke(factory); return () => factory.CreateConnection( - options.HostName.Split(new[] { "," }, StringSplitOptions.RemoveEmptyEntries)); + options.HostName.Split(new[] { "," }, StringSplitOptions.RemoveEmptyEntries), serviceName); } - + factory.HostName = options.HostName; options.ConnectionFactoryOptions?.Invoke(factory); - return () => factory.CreateConnection(); + return () => factory.CreateConnection(serviceName); } private void RabbitMQ_ConnectionShutdown(object sender, ShutdownEventArgs e)