Red Capped

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

Define the message payload

publicclassOrder{publicintId{get;set;}publicdecimalAmount{get;set;}
...}

How to publish messages

// create the queues managervarfactory=newQueueFactory("mongodb://localhost","mydb");// create the queuevarqueue=awaitfactory.CreateQueue<Order>(queueName,256*1024*1024);// publish!awaitqueue.PublishAsync(newOrder{Id=123,Amount=120M});

How to subscribe and receive messages

// create the queues managervarfactory=newQueueFactory("mongodb://localhost","mydb");// create the queuevarqueue=awaitfactory.CreateQueue<Order>(queueName,256*1024*1024);// subscribequeue.Subscribe(order =>{Debug.WriteLine("Order #{0} amount {1}",order.Id,order.Amount);// return true if the message was handled, otherwise it will be requeuedreturntrue;});