@@ -37,7 +37,13 @@ public ErrorIngestor(Metrics metrics,
3737 bulkInsertDurationMeter = metrics . GetMeter ( "Error ingestion - bulk insert duration" , FrequencyInMilliseconds ) ;
3838 var ingestedMeter = metrics . GetCounter ( "Error ingestion - ingested" ) ;
3939
40- var enrichers = new IEnrichImportedErrorMessages [ ] { new MessageTypeEnricher ( ) , new EnrichWithTrackingIds ( ) , new ProcessingStatisticsEnricher ( ) } . Concat ( errorEnrichers ) . ToArray ( ) ;
40+ var enrichers = new IEnrichImportedErrorMessages [ ]
41+ {
42+ new MessageTypeEnricher ( ) ,
43+ new EnrichWithTrackingIds ( ) ,
44+ new ProcessingStatisticsEnricher ( )
45+
46+ } . Concat ( errorEnrichers ) . ToArray ( ) ;
4147
4248 errorProcessor = new ErrorProcessor ( enrichers , failedMessageEnrichers . ToArray ( ) , domainEvents , ingestedMeter ) ;
4349 retryConfirmationProcessor = new RetryConfirmationProcessor ( domainEvents ) ;
@@ -61,6 +67,7 @@ public async Task Ingest(List<MessageContext> contexts, CancellationToken cancel
6167 }
6268 }
6369
70+
6471 var storedFailed = await PersistFailedMessages ( failedMessages , retriedMessages , cancellationToken ) ;
6572
6673 try
@@ -70,7 +77,6 @@ public async Task Ingest(List<MessageContext> contexts, CancellationToken cancel
7077 {
7178 announcerTasks . Add ( errorProcessor . Announce ( context ) ) ;
7279 }
73-
7480 foreach ( var context in retriedMessages )
7581 {
7682 announcerTasks . Add ( retryConfirmationProcessor . Announce ( context ) ) ;
@@ -84,7 +90,6 @@ public async Task Ingest(List<MessageContext> contexts, CancellationToken cancel
8490 {
8591 Logger . Debug ( $ "Forwarding { storedFailed . Count } messages") ;
8692 }
87-
8893 await Forward ( storedFailed , cancellationToken ) ;
8994 if ( Logger . IsDebugEnabled )
9095 {
@@ -128,7 +133,6 @@ async Task<IReadOnlyList<MessageContext>> PersistFailedMessages(List<MessageCont
128133 {
129134 await unitOfWork . Complete ( cancellationToken ) ;
130135 }
131-
132136 return storedFailedMessageContexts ;
133137 }
134138 catch ( Exception e )
0 commit comments