From 67b750ecbd69830bcdfa64eb22e2582a57fac2c5 Mon Sep 17 00:00:00 2001
From: tamazbagdavadzespacege <tamaz.bagdavadze@space.ge>
Date: Fri, 24 Jul 2026 08:49:45 +0400
Subject: [PATCH] replace numeric placeholders with named parameters

---
 src/DotNetCore.CAP.Kafka/IConnectionPool.Default.cs      | 2 +-
 src/DotNetCore.CAP.NATS/IConnectionPool.Default.cs       | 2 +-
 src/DotNetCore.CAP.Pulsar/IConnectionFactory.Default.cs  | 2 +-
 src/DotNetCore.CAP.RabbitMQ/ITransport.RabbitMQ.cs       | 2 +-
 src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs | 2 +-
 5 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/DotNetCore.CAP.Kafka/IConnectionPool.Default.cs b/src/DotNetCore.CAP.Kafka/IConnectionPool.Default.cs
index 5bdbbdfe6..2b702f522 100644
--- a/src/DotNetCore.CAP.Kafka/IConnectionPool.Default.cs
+++ b/src/DotNetCore.CAP.Kafka/IConnectionPool.Default.cs
@@ -24,7 +24,7 @@ public ConnectionPool(ILogger<ConnectionPool> logger, IOptions<KafkaOptions> opt
         _producerPool = new ConcurrentQueue<IProducer<string, byte[]>>();
         _maxSize = _options.ConnectionPoolSize;
 
-        logger.LogDebug("CAP Kafka servers: {0}", _options.Servers);
+        logger.LogDebug("CAP Kafka servers: {kafkaServers}", _options.Servers);
     }
 
     public string ServersAddress => _options.Servers;
diff --git a/src/DotNetCore.CAP.NATS/IConnectionPool.Default.cs b/src/DotNetCore.CAP.NATS/IConnectionPool.Default.cs
index 0af8a8720..07843472e 100644
--- a/src/DotNetCore.CAP.NATS/IConnectionPool.Default.cs
+++ b/src/DotNetCore.CAP.NATS/IConnectionPool.Default.cs
@@ -26,7 +26,7 @@ public ConnectionPool(ILogger<ConnectionPool> logger, IOptions<NATSOptions> opti
         _connectionFactory = new ConnectionFactory();
         _maxSize = _options.ConnectionPoolSize;
 
-        logger.LogDebug("NATS configuration: {0}", options.Value.Options);
+        logger.LogDebug("NATS configuration: {natsConfig}", options.Value.Options);
     }
 
     public string ServersAddress => _options.Servers;
diff --git a/src/DotNetCore.CAP.Pulsar/IConnectionFactory.Default.cs b/src/DotNetCore.CAP.Pulsar/IConnectionFactory.Default.cs
index 51eb8e214..6d63d80b2 100644
--- a/src/DotNetCore.CAP.Pulsar/IConnectionFactory.Default.cs
+++ b/src/DotNetCore.CAP.Pulsar/IConnectionFactory.Default.cs
@@ -24,7 +24,7 @@ public ConnectionFactory(ILogger<ConnectionFactory> logger, IOptions<PulsarOptio
         _options = options.Value;
         _topicProducers = new ConcurrentDictionary<string, Task<IProducer<byte[]>>>();
 
-        logger.LogDebug("CAP Pulsar configuration: {0}", JsonConvert.SerializeObject(_options, Formatting.Indented));
+        logger.LogDebug("CAP Pulsar configuration: {capPulsarConfig}", JsonConvert.SerializeObject(_options, Formatting.Indented));
     }
 
     public async ValueTask DisposeAsync()
diff --git a/src/DotNetCore.CAP.RabbitMQ/ITransport.RabbitMQ.cs b/src/DotNetCore.CAP.RabbitMQ/ITransport.RabbitMQ.cs
index 130720cfc..62ee5b1a9 100644
--- a/src/DotNetCore.CAP.RabbitMQ/ITransport.RabbitMQ.cs
+++ b/src/DotNetCore.CAP.RabbitMQ/ITransport.RabbitMQ.cs
@@ -44,7 +44,7 @@ public async Task<OperateResult> SendAsync(TransportMessage message)
 
             await channel.BasicPublishAsync(_exchange, message.GetName(), false, props, message.Body);
 
-            _logger.LogInformation("CAP message '{0}' published, internal id '{1}'", message.GetName(), message.GetId());
+            _logger.LogInformation("CAP message '{capMessageName}' published, internal id '{capMessageId}'", message.GetName(), message.GetId());
 
             return OperateResult.Success;
         }
diff --git a/src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs b/src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs
index ae1a9edda..0c2a69530 100644
--- a/src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs
+++ b/src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs
@@ -263,7 +263,7 @@ private void RegisterMessageProcessor(IConsumerClient client)
             }
             catch (Exception e)
             {
-                _logger.LogError(e, "An exception occurred when process received message. Message:'{0}'.",
+                _logger.LogError(e, "An exception occurred when process received message. Message:'{transportMessage}'.",
                     transportMessage);
 
                 await client.RejectAsync(sender);