src/Messaging.cs
/// <summary>
/// Starts a listener for the queue.
/// </summary>
/// <param name="func">
/// The method that will receive and process the messages.
/// Returns true: the processing is considered as succeeded. The message is deleted from queue.
/// Returns false: the processing is considered complete with flaws. The message returns to the queue.
/// Throws exception: the message is considered dangerous, removed from the queue and enqueued to another error queue.
/// This error queue is another queue with the same name followed by "-error", e.g. if <paramref name="queueName"/> equals "test-queue",
/// the error queue will be "test-queue-error".
/// </param>
/// <exception cref="InvalidOperationException">Occurs when the connection to the server fails.</exception>
Starts a listener for the queue.
Starts a listener for the queue .
public void StartListening(string queueName, Func<MessagingArgs, bool> func)
        {
            queueName = queueName.ToLower();
            Utils.ValidateQueueName(queueName, true);
            var transporter = GetTransporter(queueName);
            transporter.StartListening(queueName, func);
        }
public void StartListening ( string queueName , Func < MessagingArgs , bool > func ) { queueName = queueName . ToLower ( ) ; Utils . ValidateQueueName ( queueName , true ) ; var transporter = GetTransporter ( queueName ) ; transporter . StartListening ( queueName , func ) ; }
Starts a listener for the queue.
Starts a listener for the queue .
Occurs when the connection to the server fails.
Occurs when the connection to the server fails .
queueName
string
func
Func<MessagingArgs, bool>
The method that will receive and process the messages.
Returns true: the processing is considered as succeeded. The message is deleted from queue.
Returns false: the processing is considered complete with flaws. The message returns to the queue.
Throws exception: the message is considered dangerous, removed from the queue and enqueued to another error queue.
This error queue is another queue with the same name followed by "-error", e.g. if  equals "test-queue",
the error queue will be "test-queue-error".
The method that will receive and process the messages . Returns true : the processing is considered as succeeded . The message is deleted from queue . Returns false : the processing is considered complete with flaws . The message returns to the queue . Throws exception : the message is considered dangerous removed from the queue and enqueued to another error queue . This error queue is another queue with the same name followed by " - error " e . g . if equals " test - queue " the error queue will be " test - queue - error " .