Skip to content

Commit bd765a0

Browse files
committed
More rollbacks
1 parent d786a34 commit bd765a0

File tree

1 file changed

+14
-5
lines changed

1 file changed

+14
-5
lines changed

src/ServiceControl/Operations/ErrorProcessor.cs

Lines changed: 14 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,17 @@
1515
using ServiceControl.Persistence;
1616
using ServiceControl.Persistence.UnitOfWork;
1717

18-
class ErrorProcessor(IEnrichImportedErrorMessages[] enrichers,
19-
IFailedMessageEnricher[] failedMessageEnrichers,
20-
IDomainEvents domainEvents,
21-
Counter ingestedCounter)
18+
class ErrorProcessor
2219
{
20+
public ErrorProcessor(IEnrichImportedErrorMessages[] enrichers, IFailedMessageEnricher[] failedMessageEnrichers, IDomainEvents domainEvents,
21+
Counter ingestedCounter)
22+
{
23+
this.enrichers = enrichers;
24+
this.domainEvents = domainEvents;
25+
this.ingestedCounter = ingestedCounter;
26+
failedMessageFactory = new FailedMessageFactory(failedMessageEnrichers);
27+
}
28+
2329
public async Task<IReadOnlyList<MessageContext>> Process(IReadOnlyList<MessageContext> contexts, IIngestionUnitOfWork unitOfWork)
2430
{
2531
var storedContexts = new List<MessageContext>(contexts.Count);
@@ -163,7 +169,10 @@ static void RecordKnownEndpoints(EndpointDetails observedEndpoint, Dictionary<st
163169
}
164170
}
165171

166-
readonly FailedMessageFactory failedMessageFactory = new(failedMessageEnrichers);
172+
readonly IEnrichImportedErrorMessages[] enrichers;
173+
readonly IDomainEvents domainEvents;
174+
readonly Counter ingestedCounter;
175+
readonly FailedMessageFactory failedMessageFactory;
167176
static readonly ILog Logger = LogManager.GetLogger<ErrorProcessor>();
168177
}
169178
}

0 commit comments

Comments
 (0)