Red Capped

A lightweight .NET message queue system with QoS support, built on top of MongoDb.

Define the message payload

public class Order
{
  public int Id { get; set; }
  public decimal Amount { get; set; }
  ...
}

How to publish messages

// create the queues manager
var factory = new QueueFactory("mongodb://localhost", "mydb");
// create the queue
var queue = await factory.CreateQueue<Order>(queueName, 256*1024*1024);
// publish!
await queue.PublishAsync(new Order { Id = 123, Amount = 120M });

How to subscribe and receive messages

// create the queues manager
var factory = new QueueFactory("mongodb://localhost", "mydb");
// create the queue
var queue = await factory.CreateQueue<Order>(queueName, 256*1024*1024);
// subscribe
queue.Subscribe(order =>
{
  Debug.WriteLine("Order #{0} amount {1}", order.Id, order.Amount);
  // return true if the message was handled, otherwise it will be requeued
  return true;
});