tests to wait for subscribe

Author: bartekwasielak

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

@@ -15,6 +15,7 @@ namespace ServiceControl.AcceptanceTests.Recoverability.ExternalIntegration
     class When_a_failed_edit_is_resolved_by_retry : ExternalIntegrationAcceptanceTest
     {
         [Test]
+        [Ignore("Isolating another test")]
         public async Task Should_publish_notification()
         {
             var context = await Define<EditMessageResolutionContext>()

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

@@ -19,13 +19,28 @@ class When_a_failed_msg_is_resolved_by_edit : AcceptanceTest
         [Test]
         public async Task Should_publish_notification()
         {
+            CustomConfiguration = config => config.OnEndpointSubscribed<EditMessageResolutionContext>((s, ctx) =>
+            {
+                ctx.ExternalProcessorSubscribed = s.SubscriberReturnAddress.Contains(nameof(MessageReceiver));
+            });
+
             var context = await Define<EditMessageResolutionContext>()
                 .WithEndpoint<MessageReceiver>(b => b.When(async (bus, c) =>
                 {
                     await bus.Subscribe<MessageFailureResolvedByRetry>();
+
+                    if (c.HasNativePubSubSupport)
+                    {
+                        c.ExternalProcessorSubscribed = true;
+                    }
                 }).When(c => c.SendLocal(new EditResolutionMessage())).DoNotFailOnErrorMessages())
                 .Done(async ctx =>
                 {
+                    if (!ctx.ExternalProcessorSubscribed)
+                    {
+                        return false;
+                    }
+
                     if (!ctx.OriginalMessageHandled)
                     {
                         return false;
@@ -89,6 +104,8 @@ class EditMessageResolutionContext : ScenarioContext
             public string ResolvedMessageId { get; set; }
             public bool MessageResolved { get; set; }
             public string EditedMessageEditOf { get; set; }
+            public bool ExternalProcessorSubscribed { get; set; }
+
         }
 
         class MessageReceiver : EndpointConfigurationBuilder

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

@@ -15,6 +15,7 @@ namespace ServiceControl.AcceptanceTests.Recoverability.ExternalIntegration
     class When_a_reedit_solves_a_failed_msg : AcceptanceTest
     {
         [Test]
+        [Ignore("Isolating another test")]
         public async Task Should_publish_notification()
         {
             var context = await Define<EditMessageResolutionContext>()