Skip to content

Commit 8ecf7a6

Browse files
committed
chore: enhance name
1 parent ce6ec08 commit 8ecf7a6

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

projects/RabbitMQ.Client/Impl/Connection.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -228,7 +228,7 @@ internal void TakeOver(Connection other)
228228
internal async ValueTask<IConnection> OpenAsync(CancellationToken cancellationToken)
229229
{
230230
cancellationToken.ThrowIfCancellationRequested();
231-
Activity? _connectionActivity = RabbitMQActivitySource.OpenConnection(_frameHandler);
231+
Activity? connectionActivity = RabbitMQActivitySource.OpenConnection(_frameHandler);
232232
try
233233
{
234234
RabbitMqClientEventSource.Log.ConnectionOpened();
@@ -251,7 +251,7 @@ await _channel0.ConnectionOpenAsync(_config.VirtualHost, cancellationToken)
251251
}
252252
catch(Exception ex)
253253
{
254-
_connectionActivity?.ReportException(ex);
254+
connectionActivity?.ReportException(ex);
255255
try
256256
{
257257
var ea = new ShutdownEventArgs(ShutdownInitiator.Library, Constants.InternalError, "FailedOpen");

projects/RabbitMQ.Client/Impl/RabbitMQActivitySource.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ public static class RabbitMQActivitySource
8080
}
8181

8282
Activity? connectionActivity =
83-
s_connectionSource.StartRabbitMQActivity("rabbitmq connect", ActivityKind.Client);
83+
s_connectionSource.StartRabbitMQActivity("connection open", ActivityKind.Client);
8484
connectionActivity?
8585
.SetNetworkTags(frameHandler);
8686
return connectionActivity;

0 commit comments

Comments
 (0)