Producer

Producing messages

The message can be any serializable class.

Creating the queue

Creating the queue is pretty straightforward. You'll need to specify the transport you want to use.

var queueConnection = new QueueConnection(queueName, connectionString);
using (var queueContainer = new QueueContainer<InitModule>())
{
	using (var queue = queueContainer.CreateProducer<YourMessageClass>(queueConnection))
	{
		...
	}
}

If you dispose of the container, all queues created from the container will be disposed as well. If you will be sending many messages over time, you should hang on to the container/queues instead of constantly creating them.

The send commands are thread safe.

Messages can be sent in a few different ways.

A single message with no additional message metadata

var result = queue.Send(new SimpleMessage {Message = "Hello World"});

A single message with additional metadata, such as a message delay

var data = new AdditionalMessageData();
data.SetDelay(TimeSpan.FromMinutes(1));
var result = queue.Send(new SimpleMessage {Message = "Hello World"}, data);

A collection of messages with or without additional metadata. Note that this operation is not necessarily atomic

var result = queue.Send(messageList);

All of the above commands have async methods as well

var result = await queue.SendAsync(new SimpleMessage {Message = "Hello World"});

All methods return the result of the operation. This includes the following:

• A boolean indicating if an error occurred
• An exception containing the error, if an error occurred.
• Information about the sent message, assuming no errors -The message ID -The correlation ID

Methods that take in a collection of messages return a collection of results. The collection contains a boolean named 'HasErrors' that will indicate if any result failed.