diff --git a/bus/EasyCaching.Bus.RabbitMQ/DefaultRabbitMQBus.cs b/bus/EasyCaching.Bus.RabbitMQ/DefaultRabbitMQBus.cs index cc8eec84..72e6ad84 100644 --- a/bus/EasyCaching.Bus.RabbitMQ/DefaultRabbitMQBus.cs +++ b/bus/EasyCaching.Bus.RabbitMQ/DefaultRabbitMQBus.cs @@ -64,7 +64,8 @@ IPooledObjectPolicy _objectPolicy VirtualHost = _options.VirtualHost, RequestedConnectionTimeout = System.TimeSpan.FromMilliseconds(_options.RequestedConnectionTimeout), SocketReadTimeout = System.TimeSpan.FromMilliseconds(_options.SocketReadTimeout), - SocketWriteTimeout = System.TimeSpan.FromMilliseconds(_options.SocketWriteTimeout) + SocketWriteTimeout = System.TimeSpan.FromMilliseconds(_options.SocketWriteTimeout), + ClientProvidedName = _options.ClientProvidedName }; _subConnection = factory.CreateConnection(); diff --git a/src/EasyCaching.Core/Configurations/BaseRabbitMQOptions.cs b/src/EasyCaching.Core/Configurations/BaseRabbitMQOptions.cs index aae147f1..eec55588 100644 --- a/src/EasyCaching.Core/Configurations/BaseRabbitMQOptions.cs +++ b/src/EasyCaching.Core/Configurations/BaseRabbitMQOptions.cs @@ -51,5 +51,10 @@ public class BaseRabbitMQOptions /// Gets or sets queue message automatic deletion time (in milliseconds). Default 864000000 ms (10 days). /// public int QueueMessageExpires { get; set; } = 864000000; + + /// + /// Gets or sets the client-provided name for the rabbit connection. Default null (handled by rabbit client) + /// + public string ClientProvidedName { get; set; } } }