make integ test less flaky

onlyann · Sep 6, 2017 · 3c2d812 · 3c2d812
1 parent a015f1d
commit 3c2d812
Showing 1 changed file with 17 additions and 7 deletions.
diff --git a/tests/ServiceStack.AzureServiceBus.Tests/MqServerIntroTests.cs b/tests/ServiceStack.AzureServiceBus.Tests/MqServerIntroTests.cs
@@ -26,6 +26,16 @@ public class HelloIntro : IReturn<HelloIntroResponse>
         public string Name { get; set; }
     }
 
+    public class HelloGlobal : IReturn<HelloGlobalResponse>
+    {
+        public string Name { get; set; }
+    }
+
+    public class HelloGlobalResponse
+    {
+        public string Result { get; set; }
+    }
+
     public class HelloFail : IReturn<HelloFailResponse>
     {
         public string Name { get; set; }
@@ -432,8 +442,8 @@ public async Task Global_request_and_response_get_called()
             using (var mqServer = CreateMqServer())
             {
                 await Task.WhenAll(
-                    mqServer.MessageFactory.PurgeQueueAsync<HelloIntro>(),
-                    mqServer.MessageFactory.PurgeQueuesAsync(QueueNames<HelloIntroResponse>.In));
+                    mqServer.MessageFactory.PurgeQueueAsync<HelloGlobal>(),
+                    mqServer.MessageFactory.PurgeQueuesAsync(QueueNames<HelloGlobalResponse>.In));
 
                 var azureServer = mqServer as AzureBusServer;
                 azureServer.RequestFilter = msg =>
@@ -444,23 +454,23 @@ await Task.WhenAll(
 
                 azureServer.ResponseFilter = response =>
                 {
-                    if (response is HelloIntroResponse helloResp)
+                    if (response is HelloGlobalResponse helloResp)
                     {
                         helloResp.Result += "!!!";
                     }
 
                     return response;
                 };
 
-                mqServer.RegisterHandler<HelloIntro>(m =>
-                    new HelloIntroResponse { Result = $"Hello, {m.Meta["prefix"]} {m.GetBody().Name}".Fmt() });
+                mqServer.RegisterHandler<HelloGlobal>(m =>
+                    new HelloGlobalResponse { Result = $"Hello, {m.Meta["prefix"]} {m.GetBody().Name}".Fmt() });
                 mqServer.Start();
 
                 using (var mqClient = mqServer.CreateMessageQueueClient())
                 {
-                    mqClient.Publish(new HelloIntro { Name = "World" });
+                    mqClient.Publish(new HelloGlobal { Name = "World" });
 
-                    IMessage<HelloIntroResponse> responseMsg = mqClient.Get<HelloIntroResponse>(QueueNames<HelloIntroResponse>.In);
+                    IMessage<HelloGlobalResponse> responseMsg = mqClient.Get<HelloGlobalResponse>(QueueNames<HelloGlobalResponse>.In);
                     mqClient.Ack(responseMsg);
                     Assert.That(responseMsg.GetBody().Result, Is.EqualTo("Hello, Global World!!!"));
                 }