Commit 95a62bd

@@ -1,4 +1,5 @@
-using common;
+using System;
+using common;
 using common.messages;
 
 namespace client
@@ -14,6 +15,7 @@ namespace client
                 handler.handler(x);
             });
             Resolve.the<CommandProcessor>().add(receiver);
+            "sending ping {0}".log(DateTime.Now);
             Resolve.the<ServiceBus>().publish<Message>(x =>
             {
                 x.source = "client";

@@ -16,12 +16,14 @@ namespace common
 
         public override void handle(Message item)
         {
-            "received from {0}: {1} {2}".log(item.source, item.message, DateTime.Now);
+            "received {0} from {1} {2}".log(item.message, item.source, DateTime.Now);
             Thread.Sleep(5000);
+            var source = Assembly.GetEntryAssembly().GetName().Name;
+            "sending  {0} from {1} {2}".log(item.message.Equals("ping") ? "pong" : "ping", source, DateTime.Now);
             bus.publish<Message>(x =>
             {
                 x.message = item.message.Equals("ping") ? "pong" : "ping";
-                x.source = Assembly.GetEntryAssembly().GetName().Name;
+                x.source = source;
             });
         }
     }

@@ -1,47 +1,47 @@
-using System;
-using System.Collections.Generic;
-using System.Transactions;
-using Rhino.Queues;
-using Rhino.Queues.Model;
-
-namespace common
-{
-    public class RhinoReceiver : Receiver
-    {
-        List<Observer<Message>> observers = new List<Observer<Message>>();
-        IQueue queue;
-        CommandProcessor processor;
-
-        public RhinoReceiver(IQueue queue, CommandProcessor processor)
-        {
-            this.queue = queue;
-            this.processor = processor;
-        }
-
-        public void register(Observer<Message> observer)
-        {
-            observers.Add(observer);
-        }
-
-        public void run()
-        {
-            try
-            {
-                using (var transaction = new TransactionScope())
-                {
-                    var message = queue.Receive();
-                    observers.each(observer => observer(message));
-                    transaction.Complete();
-                }
-            }
-            catch (Exception e)
-            {
-                e.add_to_log();
-            }
-            finally
-            {
-                processor.add(this);
-            }
-        }
-    }
+using System;
+using System.Collections.Generic;
+using System.Transactions;
+using Rhino.Queues;
+using Rhino.Queues.Model;
+
+namespace common
+{
+    public class RhinoReceiver : Receiver
+    {
+        List<Observer<Message>> observers = new List<Observer<Message>>();
+        IQueue queue;
+        CommandProcessor processor;
+
+        public RhinoReceiver(IQueue queue, CommandProcessor processor)
+        {
+            this.queue = queue;
+            this.processor = processor;
+        }
+
+        public void register(Observer<Message> observer)
+        {
+            observers.Add(observer);
+        }
+
+        public void run()
+        {
+            try
+            {
+                using (var transaction = new TransactionScope())
+                {
+                    var message = queue.Receive();
+                    observers.each(observer => observer(message));
+                    transaction.Complete();
+                }
+            }
+            catch (Exception e)
+            {
+                e.add_to_log();
+            }
+            finally
+            {
+                processor.add(this);
+            }
+        }
+    }
 }
\ No newline at end of file

@@ -1,5 +1,4 @@
 using common;
-using common.messages;
 
 namespace server
 {
@@ -11,18 +10,9 @@ namespace server
             var handler = new MessageHandler(Resolve.the<DependencyRegistry>());
             receiver.register(x =>
             {
-                //using (var unit_of_work = Resolve.the<IUnitOfWorkFactory>().create())
-                //{
                 handler.handler(x);
-                //unit_of_work.commit();
-                //}
             });
             Resolve.the<CommandProcessor>().add(receiver);
-            Resolve.the<ServiceBus>().publish<Message>(x =>
-            {
-                x.source = "server";
-                x.message = "ping";
-            });
         }
     }
 }
\ No newline at end of file