Shorten test durations

Author: lukebakken

projects/Unit/TestFloodPublishing.cs

@@ -49,9 +49,12 @@
 namespace RabbitMQ.Client.Unit
 {
     [TestFixture]
-    public class TestFloodPublishing : IntegrationFixture
+    public class TestFloodPublishing
     {
-        [Test, Category("LongRunning")]
+        private readonly byte[] _body = new byte[2048];
+        private readonly TimeSpan _tenSeconds = TimeSpan.FromSeconds(10);
+
+        [Test]
         public void TestUnthrottledFloodPublishing()
         {
             var connFactory = new ConnectionFactory()
@@ -60,9 +63,9 @@ public void TestUnthrottledFloodPublishing()
                 AutomaticRecoveryEnabled = false
             };
 
-            using(var conn = connFactory.CreateConnection())
+            using (var conn = connFactory.CreateConnection())
             {
-                using(var model = conn.CreateModel())
+                using (var model = conn.CreateModel())
                 {
                     conn.ConnectionShutdown += (_, args) =>
                     {
@@ -73,20 +76,19 @@ public void TestUnthrottledFloodPublishing()
                     };
 
                     bool elapsed = false;
-                    using (Timer t = new Timer((_obj) => { elapsed = true; }, null, 1000 * 185, -1))
+                    using (Timer t = new Timer((_obj) => { elapsed = true; }, null, (int)_tenSeconds.TotalMilliseconds, -1))
                     {
                         while (!elapsed)
                         {
-                            model.BasicPublish("", "", null, new byte[2048]);
+                            model.BasicPublish("", "", null, _body);
                         }
                         Assert.IsTrue(conn.IsOpen);
                     }
                 }
             }
         }
 
-        // rabbitmq/rabbitmq-dotnet-client#802 FIX THIS TODO
-        [Test, Category("LongRunning")]
+        [Test]
         public async Task TestMultithreadFloodPublishing()
         {
             string message = "test message";
@@ -95,7 +97,12 @@ public async Task TestMultithreadFloodPublishing()
             int receivedCount = 0;
             byte[] sendBody = Encoding.UTF8.GetBytes(message);
 
-            var cf = new ConnectionFactory();
+            var cf = new ConnectionFactory()
+            {
+                RequestedHeartbeat = TimeSpan.FromSeconds(60),
+                AutomaticRecoveryEnabled = false
+            };
+
             using (IConnection c = cf.CreateConnection())
             {
                 using (IModel m = c.CreateModel())
@@ -118,7 +125,7 @@ public async Task TestMultithreadFloodPublishing()
                     };
 
                     string tag = m.BasicConsume(q.QueueName, true, consumer);
-                    var cts = new CancellationTokenSource(TimeSpan.FromSeconds(30));
+                    var cts = new CancellationTokenSource(_tenSeconds);
 
                     using (var timeoutRegistration = cts.Token.Register(() => tcs.SetCanceled()))
                     {