add ClientProvidedName on publisher connection

dotnetcore · Jan 16, 2024 · 3dc3652 · 3dc3652
1 parent 266bec0
commit 3dc3652
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/bus/EasyCaching.Bus.RabbitMQ/Configurations/ModelPooledObjectPolicy.cs b/bus/EasyCaching.Bus.RabbitMQ/Configurations/ModelPooledObjectPolicy.cs
@@ -28,7 +28,8 @@ private IConnection GetConnection()
                 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,
             };
 
             return factory.CreateConnection();