Skip to content

Commit 8f51146

Browse files
committed
formatting
Signed-off-by: Gabriele Santomaggio <[email protected]>
1 parent a4638b5 commit 8f51146

File tree

3 files changed

+4
-6
lines changed

3 files changed

+4
-6
lines changed

RabbitMQ.AMQP.Client/Impl/AmqpConnection.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public class AmqpConnection : AbstractLifeCycle, IConnection
3434

3535
private readonly AmqpManagement _management;
3636
private readonly RecordingTopologyListener _recordingTopologyListener = new();
37-
37+
3838
internal readonly IConnectionSettings _connectionSettings;
3939
internal readonly AmqpSessionManagement _nativePubSubSessions;
4040

RabbitMQ.AMQP.Client/Impl/IMetricsReporter.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ public ConsumerContext(string? destination, string serverAddress, int serverPort
2222
public string ServerAddress { get; }
2323
public int ServerPort { get; }
2424
}
25-
25+
2626
sealed class PublisherContext
2727
{
2828
public PublisherContext(string? destination, string serverAddress, int serverPort)

RabbitMQ.AMQP.Client/Impl/MetricsReporter.cs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,8 @@
99
namespace RabbitMQ.AMQP.Client.Impl
1010
{
1111
#if NET6_0_OR_GREATER
12-
// .NET docs on metric instrumentation: https://learn.microsoft.com/en-us/dotnet/core/diagnostics/metrics-instrumentation
13-
// OpenTelemetry semantic conventions for messaging metric: https://opentelemetry.io/docs/specs/semconv/messaging/messaging-metrics
12+
// .NET docs on metric instrumentation: https://learn.microsoft.com/en-us/dotnet/core/diagnostics/metrics-instrumentation
13+
// OpenTelemetry semantic conventions for messaging metric: https://opentelemetry.io/docs/specs/semconv/messaging/messaging-metrics
1414
internal sealed class MetricsReporter : IMetricsReporter
1515
{
1616
const string Version = "0.1.0";
@@ -75,7 +75,6 @@ static MetricsReporter()
7575
"Duration of processing operation. ");
7676
}
7777

78-
7978
public void ReportMessageSendSuccess(IMetricsReporter.PublisherContext context, long startTimestamp)
8079
{
8180
var serverAddress = new KeyValuePair<string, object?>(ServerAddress, context.ServerAddress);
@@ -97,7 +96,6 @@ public void ReportMessageSendSuccess(IMetricsReporter.PublisherContext context,
9796
}
9897
}
9998

100-
10199
public void ReportMessageSendFailure(IMetricsReporter.PublisherContext context, long startTimestamp,
102100
AmqpException amqpException)
103101
{

0 commit comments

Comments
 (0)