Moved testcase to integration test

GrumpyBusted · GrumpyBusted · commit 5c4d75402e02 · 2018-01-14T11:05:00.000+01:00
diff --git a/Grumpy.MessageQueue.Msmq.IntegrationTests/LocaleQueueTests.cs b/Grumpy.MessageQueue.Msmq.IntegrationTests/LocaleQueueTests.cs
@@ -364,6 +364,32 @@ public void SendAndReceiveDtoMessageShouldWork()
             }
         }
 
+
+        [Fact]
+        public void SendAndReceiveAsyncDtoMessageShouldWork()
+        {
+            var name = $"IntegrationTest_{UniqueKeyUtility.Generate()}";
+
+            try
+            {
+                using (var queue = CreateLocalQueue(name, true, LocaleQueueMode.DurableCreate))
+                {
+                    queue.Send(new MyDto { S = "ABC", I = 2 });
+                }
+
+                using (var queue = CreateLocalQueue(name, true, LocaleQueueMode.DurableCreate))
+                {
+                    var dto = (MyDto)queue.ReceiveAsync(100, _cancellationToken).Result.Message;
+
+                    dto.S.Should().Be("ABC");
+                    dto.I.Should().Be(2);
+                }
+            }
+            finally
+            {
+                _messageQueueManager.Delete(name, true);
+            }
+        }
         [Fact]
         public void SendMessageToReceiveWithCancellationShouldReceiveMessage()
         {
diff --git a/Grumpy.MessageQueue.Msmq.UnitTests/QueueTests.cs b/Grumpy.MessageQueue.Msmq.UnitTests/QueueTests.cs
@@ -239,17 +239,6 @@ public void ReceiveFromEmptyQueueShouldReturnNullAfterTimeout()
             }
         }
 
-        [Fact]
-        public void ReceiveAsyncFromEmptyQueueShouldReturnNullAfterTimeout()
-        {
-            SetQueue(Substitute.For<System.Messaging.MessageQueue>(), true);
-
-            using (var cut = CreateLocalQueue())
-            {
-                cut.ReceiveAsync(10, _cancellationToken).Result.Message.Should().BeNull();
-            }
-        }
-
         private IQueue CreateLocalQueue(string queue = "MyQueue", bool privateQueue = true, LocaleQueueMode localeQueueMode = LocaleQueueMode.TemporaryMaster)
         {
             return new LocaleQueue(_messageQueueManager, queue, privateQueue, localeQueueMode, true);

Original file line number	Diff line number	Diff line change
`@@ -239,17 +239,6 @@ public void ReceiveFromEmptyQueueShouldReturnNullAfterTimeout()`
`239`	`239`	`}`
`240`	`240`	`}`
`241`	`241`
`242`		`- [Fact]`
`243`		`- public void ReceiveAsyncFromEmptyQueueShouldReturnNullAfterTimeout()`
`244`		`- {`
`245`		`- SetQueue(Substitute.For<System.Messaging.MessageQueue>(), true);`
`246`		`-`
`247`		`- using (var cut = CreateLocalQueue())`
`248`		`- {`
`249`		`- cut.ReceiveAsync(10, _cancellationToken).Result.Message.Should().BeNull();`
`250`		`- }`
`251`		`- }`
`252`		`-`
`253`	`242`	`private IQueue CreateLocalQueue(string queue = "MyQueue", bool privateQueue = true, LocaleQueueMode localeQueueMode = LocaleQueueMode.TemporaryMaster)`
`254`	`243`	`{`
`255`	`244`	`return new LocaleQueue(_messageQueueManager, queue, privateQueue, localeQueueMode, true);`