API for Microsoft Message Queue (MSMQ).
This API extents the API with:
- Larger messages (Move the limit from 4MB to the size of a string 1-2GB)
- Transactional messages with Ack and NAck feature
- Queue Handler (Listener) to trigger handler method when messages are received
- Automatic management of queues (Create and Delete)
- Cancelable Receiver
- Async Receiver
This API includes the features that are most used (and needed for my other solution). The API makes the use of MSMQ easy and strait forward. I know this library is opinionated and only provide a sub set of the features in MSMQ API for Microsoft Message Queue (MSMQ).
The following code sample will:
- Create a new Private Queue on the current maschine, if not exists
- Open a connections to the queue
- Send a Message
- Receive the same message
- Close the connection
var queueFactory = new QueueFactory();
using (var queue = queueFactory.CreateLocale("MyQueue", true, LocaleQueueMode.DurableCreate, true))
{
// Message will be serialized to json and chumped into pieces, all pieces send in the same transaction
queue.Send("MyMessage");
// The receive has a timeout of 1 sec, and the message will be deserialized to the type (here string). This receive will automatically Ack the message
var response = queue.Receive<string>(1000, new CancellationToken());
}The following code sample will:
- Receive a transactional message
- Try to Handle the message in some other method
- If any exception, NAck the message for next receive to handle the samme message
var queueFactory = new QueueFactory();
using (var queue = queueFactory.CreateLocale("MyQueue", true, LocaleQueueMode.Durable, true))
{
var message = queue.Receive(1000, new CancellationToken());
try {
Handle(messege.Message)
message.Ack();
}
catch
{
message.NAck();
}
}The following code sample will:
- Create a Queue handler
- Start Listening to a Queue
- For each message call the method MessageHandler
- Ack and NAck are handled in the QueueHandler
var queueFactory = new QueueFactory();
var queueHandlerFactory = new QueueHandlerFactory(queueFactory);
using (var queueHandler = queueHandlerFactory.Create())
{
queueHandler.Start("MyQueue", true, LocaleQueueMode.Durable, true, MessageHandler, null, null, 0, true, false, new CancellationToken());
// Wait for ever, or until cancelled
}
public void MessageHandler(object message, CancellationToken cancellationToken)
{
// Do stuff with message
}Just ask for more samples!!!
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent