1using System;
 2using common;
 3using common.messages;
 4
 5namespace client
 6{
 7    public class StartServiceBus : NeedStartup
 8    {
 9        public void run()
10        {
11            var receiver = Resolve.the<RhinoReceiver>();
12            var handler = new MessageHandler(Resolve.the<DependencyRegistry>());
13            receiver.register(x =>
14            {
15                handler.handler(x);
16            });
17            Resolve.the<CommandProcessor>().add(receiver);
18            "sending ping {0}".log(DateTime.Now);
19            Resolve.the<ServiceBus>().publish<Message>(x =>
20            {
21                x.source = "client";
22                x.message = "ping";
23            });
24        }
25    }
26}