Skip to content

Commit 815ba95

Browse files
committed
WIP
1 parent 95294e7 commit 815ba95

File tree

4 files changed

+78
-0
lines changed

4 files changed

+78
-0
lines changed
Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
namespace ServiceControl.Contracts.MessageFailures
2+
{
3+
using Infrastructure.DomainEvents;
4+
5+
public class MessageEditedAndRetried : IDomainEvent
6+
{
7+
public string FailedMessageId { get; set; }
8+
public string RetriedMessageId { get; set; }
9+
public string EditId { get; set; }
10+
}
11+
}
12+
13+
//TODO: Move this to ServiceControl.Contracts package
14+
namespace ServiceControl.Contracts
15+
{
16+
public class MessageEditedAndRetried
17+
{
18+
public string FailedMessageId { get; set; }
19+
public string RetriedMessageId { get; set; }
20+
public string EditId { get; set; }
21+
}
22+
}

src/ServiceControl/Contracts/MessageFailures/MessageFailureResolvedByRetry.cs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,4 +8,11 @@ public partial class MessageFailureResolvedByRetry : IDomainEvent, IUserInterfac
88
public string FailedMessageId { get; set; }
99
public string[] AlternativeFailedMessageIds { get; set; }
1010
}
11+
12+
public class MessageEditedAndRetried : IDomainEvent
13+
{
14+
public string FailedMessageId { get; set; }
15+
public string RetriedMessageId { get; set; }
16+
public string EditId { get; set; }
17+
}
1118
}
Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
namespace ServiceControl.Recoverability.ExternalIntegration;
2+
3+
using System.Collections.Generic;
4+
using System.Threading.Tasks;
5+
using Contracts.MessageFailures;
6+
using ExternalIntegrations;
7+
8+
class MessageEditedAndRetriedPublisher : EventPublisher<MessageEditedAndRetried,
9+
MessageEditedAndRetriedPublisher.DispatchContext>
10+
{
11+
protected override DispatchContext CreateDispatchRequest(MessageEditedAndRetried @event)
12+
{
13+
throw new System.NotImplementedException();
14+
}
15+
16+
protected override Task<IEnumerable<object>> PublishEvents(IEnumerable<DispatchContext> contexts)
17+
{
18+
throw new System.NotImplementedException();
19+
}
20+
21+
public class DispatchContext
22+
{
23+
public string FailedMessageId { get; set; }
24+
public string RetriedMessageId { get; set; }
25+
public string EditId { get; set; }
26+
}
27+
28+
}

src/ServiceControl/Recoverability/ExternalIntegration/MessageFailureResolvedByRetryPublisher.cs

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,27 @@ namespace ServiceControl.Recoverability.ExternalIntegration
66
using Contracts.MessageFailures;
77
using ExternalIntegrations;
88

9+
class MessageEditedAndRetriedPublisher : EventPublisher<MessageEditedAndRetried,
10+
MessageEditedAndRetriedPublisher.DispatchContext>
11+
{
12+
protected override DispatchContext CreateDispatchRequest(MessageEditedAndRetried @event)
13+
{
14+
throw new System.NotImplementedException();
15+
}
16+
17+
protected override Task<IEnumerable<object>> PublishEvents(IEnumerable<DispatchContext> contexts)
18+
{
19+
throw new System.NotImplementedException();
20+
}
21+
22+
public class DispatchContext
23+
{
24+
public string FailedMessageId { get; set; }
25+
public string RetriedMessageId { get; set; }
26+
public string EditId { get; set; }
27+
}
28+
29+
}
930
class MessageFailureResolvedByRetryPublisher : EventPublisher<MessageFailureResolvedByRetry, MessageFailureResolvedByRetryPublisher.DispatchContext>
1031
{
1132
protected override DispatchContext CreateDispatchRequest(MessageFailureResolvedByRetry @event)

0 commit comments

Comments
 (0)