Lokad.CQRS.Sample + ZeroMQ = client update notifications (https://groups.google.com/d/topic/lokad/kD53JYzkV0o/discussion)

gistfile1.cs

// see Google Groups topic at https://groups.google.com/d/topic/lokad/kD53JYzkV0o/discussion

// example event handler in a projection
// _clients is an instance of IClientNotificationService
public void When(Source<NewAppointmentRegistered> source)
{
    NewAppointmentRegistered e = source.Event;
    DateTime dateTime = e.DateTime.Date;

    _writer.UpdateEnforcingNew(dateTime, dayDto => AddNewAppointmentToDayDto(dayDto, e.Id, ...));

    _clients.Publish("day-" + dateTime.ToString(DateTimeFormat));
}

// ZeroMQ publisher (server)
class ClientNotificationService : IClientNotificationService, IDisposable
{
    private readonly Context _context;
    private readonly Socket _publisher;

    public ClientNotificationService()
    {
        _context = new Context(1);
        _publisher = _context.Socket(SocketType.PUB);
        _publisher.Bind("tcp://*:5556");
    }

    public void Publish(string message)
    {
        _publisher.Send(message, Encoding.Unicode);
    }

    public void Dispose()
    {
        _publisher.Dispose();
        _context.Dispose();
    }
}

// ZeroMQ subscriber (client)
var ctx = new Context(1);
Task.Factory.StartNew(() =>
                          {
                              using (Socket eh = ctx.Socket(SocketType.SUB))
                              {
                                  eh.Connect("tcp://localhost:5556");
                                  eh.Subscribe("", Encoding.Unicode);
                                  while (true)
                                  {
                                      string message = eh.Recv(Encoding.Unicode);
                                      if (message.StartsWith("day")) ReloadDay(message.Split('-')[1]);
                                      else if (message == "...") ...;
                                      ...
                                  }
                              }
                          });

Nice concept!

Posted a few suggestions back to the discussion: https://groups.google.com/d/topic/lokad/kD53JYzkV0o/discussion