Forwarder.cs

    public class SSSBMessageForwarder  : IWantToRunAtStartup
    {
        readonly IBus _bus;
        readonly ITransport _transport;

        public SSSBMessageForwarder(IBus bus, ISSSBTransportFactory transportFactory)
        {
            _bus = bus;
            _transport = transportFactory.GetTransport();

            _transport.TransportMessageReceived += TransportMessageReceived;
        }

        void TransportMessageReceived(object sender, TransportMessageReceivedEventArgs e)
        {
            _bus.SendLocal(e.Message.Body[0]);
        }

        public void Run()
        {
            _transport.Start();
        }

        public void Stop()
        {
            _transport.Dispose();
        }
    }