diff --git a/src/ServiceControl/Recoverability/ExternalIntegration/MessageFailedPublisher.cs b/src/ServiceControl/Recoverability/ExternalIntegration/MessageFailedPublisher.cs deleted file mode 100644 index 38ae30155d..0000000000 --- a/src/ServiceControl/Recoverability/ExternalIntegration/MessageFailedPublisher.cs +++ /dev/null @@ -1,41 +0,0 @@ -namespace ServiceControl.Recoverability.ExternalIntegration -{ - using System; - using System.Collections.Generic; - using System.Linq; - using System.Threading; - using System.Threading.Tasks; - using Contracts.MessageFailures; - using ExternalIntegrations; - using ServiceControl.Persistence; - - class MessageFailedPublisher : EventPublisher - { - readonly IFailedMessageQueryDataStore dataStore; - - public MessageFailedPublisher(IFailedMessageQueryDataStore dataStore) - { - this.dataStore = dataStore; - } - - protected override DispatchContext CreateDispatchRequest(MessageFailed @event) - { - return new DispatchContext - { - FailedMessageId = new Guid(@event.FailedMessageId) - }; - } - - protected override async Task> PublishEvents(IEnumerable contexts, CancellationToken cancellationToken = default) - { - var ids = contexts.Select(x => x.FailedMessageId).ToArray(); - var results = await dataStore.GetFailedMessagesByIds(ids, cancellationToken); - return results.Select(x => x.ToEvent()); - } - - public class DispatchContext - { - public Guid FailedMessageId { get; set; } - } - } -} \ No newline at end of file diff --git a/src/ServiceControl/Recoverability/RecoverabilityComponent.cs b/src/ServiceControl/Recoverability/RecoverabilityComponent.cs index ab17793427..2e4c99b451 100644 --- a/src/ServiceControl/Recoverability/RecoverabilityComponent.cs +++ b/src/ServiceControl/Recoverability/RecoverabilityComponent.cs @@ -125,7 +125,6 @@ public override void Configure(Settings settings, ITransportCustomization transp services.AddEventLogMapping(); services.AddEventLogMapping(); services.AddEventLogMapping(); - services.AddEventLogMapping(); services.AddEventLogMapping(); services.AddEventLogMapping(); services.AddEventLogMapping();