.NET MSMQ - 1.0

using System;
using System.Collections.Generic;
using System.Messaging;
using Castle.Windsor;
using DddCqrsEsExample.Framework;
using Newtonsoft.Json;

namespace DddCqrsEsExample.Web2.Infrastructure
{
    public class MsmqEventBus : IEventBus
    {
        private readonly IWindsorContainer _container;

        private const string QueueName = @".\private$\DddCqrsEsQueue";

        public MsmqEventBus(IWindsorContainer container)
        {
            if (container == null) throw new ArgumentNullException(nameof(container));
            _container = container;
        }

        public void Publish<TEvent>(TEvent evt) where TEvent : Event
        {
            HandleEvent(evt);

            PublishOnMsmq(evt);
        }

        private void HandleEvent<TEvent>(TEvent evt) where TEvent : Event
        {
            var handlerType = typeof(IEventHandler<>).MakeGenericType(evt.GetType());
            var handlers = _container.ResolveAll(handlerType);
            foreach (var handler in handlers)
            {
                try
                {
                    var handleMethod = handler.GetType().GetMethod("Handle");
                    handleMethod.Invoke(handler, new object[] {evt});
                }
                finally
                {
                    _container.Release(handler);
                }
            }
        }

        private static void PublishOnMsmq<TEvent>(TEvent evt) where TEvent : Event
        {
            if (!MessageQueue.Exists(QueueName))
            {
                MessageQueue.Create(QueueName);
            }

            using (var q = new MessageQueue(QueueName))
            {
                q.DefaultPropertiesToSend.Recoverable = true;

                q.Send(JsonConvert.SerializeObject(evt, Formatting.Indented) + "|" + evt.GetType().AssemblyQualifiedName);
            }
        }

using System;
using System.Messaging;
using DddCqrsEsExample.Framework;
using DddCqrsEsExample.ThinReadLayer.Core;
using Newtonsoft.Json;

namespace DddCqrsEsExample.ThinReadLayer.EventListener
{
    public class Listener
    {
        private const string QueueName = @".\private$\DddCqrsEsQueue";
        private MessageQueue _listeningQueue;

        public void Start()
        {
            if (!MessageQueue.Exists(QueueName))
            {
                MessageQueue.Create(QueueName);
            }

            try
            {
                if (MessageQueue.Exists(QueueName))
                {
                    _listeningQueue = new MessageQueue(QueueName);
                    _listeningQueue.ReceiveCompleted +=
                        (sender, args) =>
                        {
                            args.Message.Formatter = new XmlMessageFormatter(new[] {typeof(string)});
                            var msg = args.Message.Body.ToString();

                            Console.WriteLine("Message received:{0}", msg);

                            var parts = msg.Split('|');
                            var json = parts[0];
                            var typeName = parts[1];
                            var type = Type.GetType(typeName);
                            var evt = (Event)JsonConvert.DeserializeObject(json, type);

                            new Denormaliser().StoreEvent(evt);

                            _listeningQueue.BeginReceive();
                        };
                    _listeningQueue.BeginReceive();
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(string.Format("Unable to initialise message queue on your local machine.\r\n\r\n{0}", e));
            }
        }
    }
}