Start publisher before subscriber, add some queries in.

seif · Feb 26, 2012 · f3a65f1 · f3a65f1
1 parent 2d6bf23
commit f3a65f1
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/src/NHibernate.ZMELogPublisher.Tests/PublisherTests.cs b/src/NHibernate.ZMELogPublisher.Tests/PublisherTests.cs
@@ -62,12 +62,13 @@ public void RunBeforeEachTest()
         [Ignore]
         public void OpeningMultipleSessionsInDifferentThreads()
         {
+
+            Publisher.Start();
+
             int expectedSessions = 100;
             subscriberTask = new Task(() => this.StartSubscriber(expectedSessions));
             subscriberTask.Start(); // start subscriber to listen to messages
 
-            Publisher.Start();
-
             Task[] tasks = new Task[expectedSessions];
             for (int i = 0; i < expectedSessions; i++)
             {
@@ -159,6 +160,9 @@ private void OpenSessionAndSave(Animal animal)
 
                     tx.Commit();
                 }
+                var animals = session.QueryOver<Animal>().List();
+                var dogs = session.QueryOver<Dog>().List();
+                var lizards = session.QueryOver<Lizard>().List();
             }
         }
 
@@ -180,7 +184,6 @@ private void StartSubscriber(int expectedSessions)
                     message = subscriber.Recv(Encoding.Unicode, 10);
                     if (message != null)
                     {
-                        Console.WriteLine(message);
                         this.recievedMessages.Add(message);
                     }
                 }