SendMessageBatchRequest

This example shows how to send messages in batch.

Batch send messages example

    var client = new AmazonSQSClient();

    var entry1 = new SendMessageBatchRequestEntry
    {
        DelaySeconds = 0,
        Id = "Entry1",
        MessageAttributes = new Dictionary<string, MessageAttributeValue>
        {
            {
                "MyNameAttribute", new MessageAttributeValue
                    { DataType = "String", StringValue = "John Doe" }
            },
            {
                "MyAddressAttribute", new MessageAttributeValue
                    { DataType = "String", StringValue = "123 Main St." }
            },
            {
                "MyRegionAttribute", new MessageAttributeValue
                    { DataType = "String", StringValue = "Any Town, United States" }
            }
        },
        MessageBody = "John Doe customer information."
    };

    var entry2 = new SendMessageBatchRequestEntry
    {
        DelaySeconds = 0,
        Id = "Entry2",
        MessageAttributes = new Dictionary<string, MessageAttributeValue>
{
  {
    "MyNameAttribute", new MessageAttributeValue
      { DataType = "String", StringValue = "Jane Doe" }
  },
  {
    "MyAddressAttribute", new MessageAttributeValue
      { DataType = "String", StringValue = "456 Center Road" }
  },
  {
    "MyRegionAttribute", new MessageAttributeValue
      { DataType = "String", StringValue = "Any City, United States" }
  }
},
        MessageBody = "Jane Doe customer information."
    };

    var entry3 = new SendMessageBatchRequestEntry
    {
        DelaySeconds = 0,
        Id = "Entry3",
        MessageAttributes = new Dictionary<string, MessageAttributeValue>
{
  {
    "MyNameAttribute", new MessageAttributeValue
      { DataType = "String", StringValue = "Richard Doe" }
  },
  {
    "MyAddressAttribute", new MessageAttributeValue
      { DataType = "String", StringValue = "789 East Blvd." }
  },
  {
    "MyRegionAttribute", new MessageAttributeValue
      { DataType = "String", StringValue = "Anywhere, United States" }
  }
},
        MessageBody = "Richard Doe customer information."
    };

    var request = new SendMessageBatchRequest
    {
        Entries = new List<SendMessageBatchRequestEntry>() { entry1, entry2, entry3 },
        QueueUrl = "https://sqs.us-east-1.amazonaws.com/80398EXAMPLE/MyTestQueue"
    };

    var response = await client.SendMessageBatchAsync(request);

    if (response.Successful != null)
    {
        Console.WriteLine("Successfully sent:");

        foreach (var success in response.Successful)
        {
            Console.WriteLine("  For ID: '" + success.Id + "':");
            Console.WriteLine("    Message ID = " + success.MessageId);
            Console.WriteLine("    MD5 of message attributes = " +
              success.MD5OfMessageAttributes);
            Console.WriteLine("    MD5 of message body = " +
              success.MD5OfMessageBody);
        }
    }

    if (response.Failed != null)
    {
        Console.WriteLine("Failed to be sent:");

        foreach (var fail in response.Failed)
        {
            Console.WriteLine("  For ID '" + fail.Id + "':");
            Console.WriteLine("    Code = " + fail.Code);
            Console.WriteLine("    Message = " + fail.Message);
            Console.WriteLine("    Sender's fault? = " +
              fail.SenderFault);
        }
    }