Skip to content

Commit 77b2c2c

Browse files
committed
Fix formatting
1 parent 9652aa0 commit 77b2c2c

File tree

1 file changed

+2
-10
lines changed

1 file changed

+2
-10
lines changed

src/ServiceControl.Audit/Auditing/AuditIngestor.cs

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22
{
33
using System;
44
using System.Collections.Generic;
5-
using System.Diagnostics;
65
using System.Linq;
76
using System.Threading.Tasks;
87
using Infrastructure.Settings;
@@ -30,15 +29,7 @@ ITransportCustomization transportCustomization
3029
{
3130
this.settings = settings;
3231
this.messageDispatcher = messageDispatcher;
33-
var enrichers = new IEnrichImportedAuditMessages[]
34-
{
35-
new MessageTypeEnricher(),
36-
new EnrichWithTrackingIds(),
37-
new ProcessingStatisticsEnricher(),
38-
new DetectNewEndpointsFromAuditImportsEnricher(endpointInstanceMonitoring),
39-
new DetectSuccessfulRetriesEnricher(),
40-
new SagaRelationshipsEnricher()
41-
}.Concat(auditEnrichers).ToArray();
32+
var enrichers = new IEnrichImportedAuditMessages[] { new MessageTypeEnricher(), new EnrichWithTrackingIds(), new ProcessingStatisticsEnricher(), new DetectNewEndpointsFromAuditImportsEnricher(endpointInstanceMonitoring), new DetectSuccessfulRetriesEnricher(), new SagaRelationshipsEnricher() }.Concat(auditEnrichers).ToArray();
4233

4334
logQueueAddress = transportCustomization.ToTransportQualifiedQueueName(settings.AuditLogQueue);
4435

@@ -67,6 +58,7 @@ public async Task Ingest(List<MessageContext> contexts)
6758
{
6859
Log.Debug($"Forwarding {stored.Count} messages");
6960
}
61+
7062
await Forward(stored, logQueueAddress);
7163
if (Log.IsDebugEnabled)
7264
{

0 commit comments

Comments
 (0)