Skip to content

Commit 7cb34ef

Browse files
authored
Exclude RetryConsumeContext logs (R-RETRY) (#241)
* Exclude RetryConsumeContext logs (R-RETRY) * Removed excluding log through r-retry (and removed test)
1 parent 85d34e2 commit 7cb34ef

File tree

2 files changed

+5
-33
lines changed

2 files changed

+5
-33
lines changed

src/ProjectOrigin.Stamp.Server/Extensions/IConfigurationExtensions.cs

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ public static WebApplication BuildApp(this IConfigurationRoot configuration)
5252

5353
builder.Logging.ClearProviders();
5454
builder.Logging.AddSerilog(Log.Logger);
55+
builder.Host.UseSerilog(Log.Logger);
5556

5657
var startup = new Startup(builder.Configuration);
5758
startup.ConfigureServices(builder.Services);
@@ -66,10 +67,11 @@ public static Serilog.ILogger GetSeriLogger(this IConfiguration configuration)
6667
var loggerConfiguration = new LoggerConfiguration()
6768
.Filter.ByExcluding("RequestPath like '/health%'")
6869
.Filter.ByExcluding("RequestPath like '/metrics%'")
69-
.Filter.ByExcluding("SourceContext = 'MassTransit.ReceiveTransport' and MessageTemplate like 'R-RETRY%'")
7070
.Filter.ByExcluding(logEvent =>
71-
logEvent.MessageTemplate.Text.Contains("R-RETRY") &&
72-
logEvent.MessageTemplate.Text.Contains("MassTransit.ReceiveTransport"))
71+
logEvent.Properties.TryGetValue("SourceContext", out var source)
72+
&& source.ToString().Contains("MassTransit.ReceiveTransport")
73+
&& logEvent.Properties.TryGetValue("MessageType", out var type)
74+
&& type.ToString().Contains("RetryConsumeContext"))
7375
.Enrich.WithSpan();
7476

7577
var logOutputFormat = configuration.GetValue<string>("LogOutputFormat");

src/ProjectOrigin.Stamp.Test/Serilog/ConfigurationExtensionsTests.cs

Lines changed: 0 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -47,34 +47,4 @@ public void LogOutput_WithMassTransitRRetryInStructuredLogging_ExcludesLogs()
4747
// Assert
4848
Assert.DoesNotContain("R-RETRY", logOutput);
4949
}
50-
51-
[Fact]
52-
public void LogOutput_WithMassTransitRRetryInJsonLogging_ExcludesLogs()
53-
{
54-
// Arrange
55-
var inMemorySettings = new List<KeyValuePair<string, string?>>
56-
{
57-
new("LogOutputFormat", "json")
58-
};
59-
60-
var configuration = new ConfigurationBuilder()
61-
.AddInMemoryCollection(inMemorySettings)
62-
.Build();
63-
64-
var output = new StringWriter();
65-
Console.SetOut(output);
66-
67-
var logger = configuration.GetSeriLogger();
68-
69-
var jsonString = @"{""Timestamp"":""2025-07-04T08:40:09.5774548+00:00"",""Level"":""Warning"",""MessageTemplate"":""R-RETRY {InputAddress} {MessageId} {MessageType}"",""TraceId"":""0f42ca4998cdada788181186db329640"",""SpanId"":""b5346b195559e7cd"",""Exception"":""ProjectOrigin.Stamp.Server.EventHandlers.RegistryTransactionStillProcessingException: Transaction wAlcfUeOfWF7iUO3pmKXi+djR+zYATURjo69utxFt6Q= is still processing on registry for certificateId: 6a1d25a9-6787-494f-a588-9fb7f6bac37c.\n at ProjectOrigin.Stamp.Server.EventHandlers.WaitForCommittedRegistryTransactionConsumer.Consume(ConsumeContext`1 context) in /src/ProjectOrigin.Stamp.Server/EventHandlers/WaitForCommittedRegistryTransactionConsumer.cs:line 76\n at MassTransit.DependencyInjection.ScopeConsumerFactory`1.Send[TMessage](ConsumeContext`1 context, IPipe`1 next) in /_/src/MassTransit/DependencyInjection/DependencyInjection/ScopeConsumerFactory.cs:line 22\n at MassTransit.DependencyInjection.ScopeConsumerFactory`1.Send[TMessage](ConsumeContext`1 context, IPipe`1 next) in /_/src/MassTransit/DependencyInjection/DependencyInjection/ScopeConsumerFactory.cs:line 22\n at MassTransit.Middleware.ConsumerMessageFilter`2.MassTransit.IFilter<MassTransit.ConsumeContext<TMessage>>.Send(ConsumeContext`1 context, IPipe`1 next) in /_/src/MassTransit/Middleware/ConsumerMessageFilter.cs:line 48\n at MassTransit.Middleware.ConsumerMessageFilter`2.MassTransit.IFilter<MassTransit.ConsumeContext<TMessage>>.Send(ConsumeContext`1 context, IPipe`1 next) in /_/src/MassTransit/Middleware/ConsumerMessageFilter.cs:line 73\n at MassTransit.Middleware.RetryFilter`1.MassTransit.IFilter<TContext>.Send(TContext context, IPipe`1 next) in /_/src/MassTransit/Middleware/RetryFilter.cs:line 47"",""Properties"":{""InputAddress"":""rabbitmq://rabbitmq/wait-for-committed-registry-transaction"",""MessageId"":""01000000-b436-1ef5-45cb-08ddbad6627f"",""MessageType"":""MassTransit.RetryPolicies.RetryConsumeContext<ProjectOrigin.Stamp.Server.EventHandlers.CertificateSentToRegistryEvent>"",""SourceContext"":""MassTransit.ReceiveTransport"",""SpanId"":""b5346b195559e7cd"",""TraceId"":""0f42ca4998cdada788181186db329640"",""ParentId"":""2235a58033c47f60""}}";
70-
71-
// Act
72-
logger.Warning(jsonString);
73-
74-
Log.CloseAndFlush();
75-
var logOutput = output.ToString();
76-
77-
// Assert
78-
Assert.DoesNotContain("R-RETRY", logOutput);
79-
}
8050
}

0 commit comments

Comments
 (0)