Skip to content

Commit e3bd5fd

Browse files
debug attempt
amend amend another attempt
1 parent 43244c9 commit e3bd5fd

File tree

2 files changed

+20
-10
lines changed

2 files changed

+20
-10
lines changed

src/ServiceControl.AcceptanceTests/Recoverability/ExternalIntegration/When_a_failed_edit_is_resolved_by_retry.cs

Lines changed: 17 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ namespace ServiceControl.AcceptanceTests.Recoverability.ExternalIntegration
1212
using ServiceControl.MessageFailures;
1313
using ServiceControl.MessageFailures.Api;
1414
using JsonSerializer = System.Text.Json.JsonSerializer;
15+
using ServiceBus.Management.Infrastructure.Settings;
1516

1617
class When_a_failed_edit_is_resolved_by_retry : ExternalIntegrationAcceptanceTest
1718
{
@@ -102,7 +103,7 @@ public async Task Should_publish_notification()
102103
}
103104

104105

105-
class EditMessageResolutionContext : ScenarioContext
106+
public class EditMessageResolutionContext : ScenarioContext
106107
{
107108
public bool OriginalMessageHandled { get; set; }
108109
public bool EditedMessage { get; set; }
@@ -117,15 +118,22 @@ class EditMessageResolutionContext : ScenarioContext
117118
public bool RetriedMessage { get; set; }
118119
}
119120

120-
class MessageReceiver : EndpointConfigurationBuilder
121+
public class MessageReceiver : EndpointConfigurationBuilder
121122
{
122-
public MessageReceiver()
123-
{
124-
CustomEndpointName("simpleendpoint1");
125-
EndpointSetup<DefaultServerWithoutAudit>(c => c.NoRetries());
126-
}
123+
public MessageReceiver() =>
124+
EndpointSetup<DefaultServerWithoutAudit>(c =>
125+
{
126+
var routing = c.ConfigureRouting();
127+
routing.RouteToEndpoint(typeof(FailedMessagesArchived).Assembly,
128+
Settings.DEFAULT_INSTANCE_NAME);
129+
},
130+
publisherMetadata =>
131+
{
132+
publisherMetadata.RegisterPublisherFor<FailedMessagesArchived>(Settings.DEFAULT_INSTANCE_NAME);
133+
});
134+
127135

128-
class EditMessageResolutionHandler(EditMessageResolutionContext testContext)
136+
public class EditMessageResolutionHandler(EditMessageResolutionContext testContext)
129137
: IHandleMessages<EditResolutionMessage>, IHandleMessages<MessageFailureResolvedByRetry>
130138
{
131139
public Task Handle(EditResolutionMessage message, IMessageHandlerContext context)
@@ -156,10 +164,9 @@ public Task Handle(MessageFailureResolvedByRetry message, IMessageHandlerContext
156164
}
157165
}
158166

159-
class EditResolutionMessage : IMessage
167+
public class EditResolutionMessage : IMessage
160168
{
161169
public bool HasBeenEdited { get; init; }
162-
public bool HasBeenRetried { get; init; }
163170
}
164171
}
165172
}

src/ServiceControl.AcceptanceTests/Recoverability/ExternalIntegration/When_a_failed_msg_is_resolved_by_edit.cs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
namespace ServiceControl.AcceptanceTests.Recoverability.ExternalIntegration
22
{
33
using System.Collections.Generic;
4+
using System.Diagnostics;
45
using System.Linq;
56
using System.Threading.Tasks;
67
using AcceptanceTesting;
@@ -11,6 +12,7 @@ namespace ServiceControl.AcceptanceTests.Recoverability.ExternalIntegration
1112
using NUnit.Framework;
1213
using ServiceControl.MessageFailures;
1314
using ServiceControl.MessageFailures.Api;
15+
using TestSupport;
1416
using JsonSerializer = System.Text.Json.JsonSerializer;
1517

1618
class When_a_failed_msg_is_resolved_by_edit : ExternalIntegrationAcceptanceTest
@@ -114,6 +116,7 @@ public Task Handle(EditResolutionMessage message, IMessageHandlerContext context
114116

115117
public Task Handle(MessageFailureResolvedByRetry message, IMessageHandlerContext context)
116118
{
119+
Debug.WriteLine($"HHHHHH - handling message {message.FailedMessageId}");
117120
testContext.ResolvedMessageId.Add(message.FailedMessageId);
118121
testContext.MessageResolved = true;
119122
return Task.CompletedTask;

0 commit comments

Comments
 (0)