Cosmetic (layout, brace alignment)

Author: hyperthunk

projects/client/Unit/src/unit/TestMessagePatternsSubscription.cs

@@ -50,9 +50,11 @@
 using RabbitMQ.Client.Events;
 using RabbitMQ.Client.MessagePatterns;
 
-namespace RabbitMQ.Client.Unit {
+namespace RabbitMQ.Client.Unit
+{
     [TestFixture]
-    public class TestMessagePatternsSubscription : IntegrationFixture {
+    public class TestMessagePatternsSubscription : IntegrationFixture
+    {
         UTF8Encoding enc = new UTF8Encoding();
 
         [Test]
@@ -90,6 +92,44 @@ public void TestSubscriptionNack()
             TestSubscriptionAction((s) => s.Nack(false, false));
         }
 
+        [Test]
+        public void TestConcurrentIterationAndAck()
+        {
+            TestConcurrentIterationWithDrainer((s) => s.Ack());
+        }
+
+        [Test]
+        public void TestConcurrentIterationAndNack()
+        {
+            TestConcurrentIterationWithDrainer((s) => s.Nack(false, false));
+        }
+
+        protected void TestConcurrentIterationWithDrainer(SubscriptionAction act)
+        {
+            IDictionary<string, object> args = new Dictionary<string, object>
+            {
+                {"x-message-ttl", 5000}
+            };
+            string q = Model.QueueDeclare("", false, true, false, args);
+            Subscription sub = new Subscription(Model, q, false);
+
+            PreparedQueue(q);
+
+            List<Thread> ts = new List<Thread>();
+            for (int i = 0; i < 50; i++)
+            {
+                SubscriptionDrainer drainer = new SubscriptionDrainer(sub, act);
+                Thread t = new Thread(drainer.Drain);
+                ts.Add(t);
+                t.Start();
+            }
+
+            foreach(Thread t in ts)
+            {
+                t.Join();
+            }
+        }
+
         private void TestSubscriptionAction(SubscriptionAction action)
         {
             Model.BasicQos(0, 1, false);
@@ -129,15 +169,18 @@ public void Drain()
                         {
                             Assert.That(ea, Is.TypeOf(typeof(BasicDeliverEventArgs)));
                             this.PostProcess(m_subscription);
-                        } else
+                        }
+                        else
                         {
                             break;
                         }
                     }
-                } catch (AlreadyClosedException ace)
+                }
+                catch (AlreadyClosedException ace)
                 {
                     // expected
-                } finally
+                }
+                finally
                 {
                     m_subscription.Close();
                 }
@@ -146,44 +189,6 @@ public void Drain()
             }
         }
 
-        [Test]
-        public void TestConcurrentIterationAndAck()
-        {
-            TestConcurrentIterationWithDrainer((s) => s.Ack());
-        }
-
-        [Test]
-        public void TestConcurrentIterationAndNack()
-        {
-            TestConcurrentIterationWithDrainer((s) => s.Nack(false, false));
-        }
-
-        protected void TestConcurrentIterationWithDrainer(SubscriptionAction act)
-        {
-            IDictionary<string, object> args = new Dictionary<string, object>
-            {
-                {"x-message-ttl", 5000}
-            };
-            string q = Model.QueueDeclare("", false, true, false, args);
-            Subscription sub = new Subscription(Model, q, false);
-
-            PreparedQueue(q);
-
-            List<Thread> ts = new List<Thread>();
-            for (int i = 0; i < 50; i++)
-            {
-                SubscriptionDrainer drainer = new SubscriptionDrainer(sub, act);
-                Thread t = new Thread(drainer.Drain);
-                ts.Add(t);
-                t.Start();
-            }
-
-            foreach(Thread t in ts)
-            {
-                t.Join();
-            }
-        }
-
         private void PreparedQueue(string q)
         {
             for (int i = 0; i < 1024; i++)