SSSBMessageForwarder

gistfile1.txt

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

        public Forwarder(IBus bus, IYourOwnTransportFactory transportFactory)
        {
            _bus = bus;
            _transport = transportFactory.GetTransport();

            _transport.TransportMessageReceived += TransportMessageReceived;
        }

        void TransportMessageReceived(object sender, TransportMessageReceivedEventArgs e)
        {
            var message = e.Message.Body[0];

            _bus.SendLocal(message);
        }

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

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