FIFO Queue Support in AmazonSQS Component

The AmazonSQS component in IPWorks MQ provides full support for working with FIFO (First-In-First-Out) queues, enabling ordered and exactly-once message processing. FIFO queues are identified by the .fifo suffix in the queue name, and can be managed directly through the component APIs.

The following examples demonstrate basic operations with FIFO queues.

Create a FIFO Queue

Amazonsqs sqs = new Amazonsqs();
// ...
sqs.CreateQueue("my-queue.fifo");

List FIFO Queues

Amazonsqs sqs = new Amazonsqs();
// ...
sqs.OnQueue += (obj, ev) =>
{
  if(ev.QueueId.EndsWith(".fifo"))
    Console.WriteLine(ev.QueueId + " | " + ev.URL);
};
sqs.ListQueues();

Create Message in a FIFO Queue

Amazonsqs sqs = new Amazonsqs();
// ...
sqs.CreateMessage("my-queue.fifo", "Just a test.");

Delete a Message in a FIFO Queue

Amazonsqs sqs = new Amazonsqs();
// ...
sqs.ListMessages("my-queue.fifo");
sqs.DeleteMessage("my-queue.fifo", sqs.Messages[0].ReceiptHandle);