Where:
queueName - The name of the queue.
message - The message to send.
""";
if (args.length != 2) {
System.out.println(usage);
System.exit(1);
}
String queueName = args[0];
String message = args[1];
SqsClient sqsClient = SqsClient.builder()
.region(Region.US_WEST_2)
.build();
sendMessage(sqsClient, queueName, message);
sqsClient.close();
}
public static void sendMessage(SqsClient sqsClient, String queueName, String message) {
try {
CreateQueueRequest request = CreateQueueRequest.builder()
.queueName(queueName)
.build();
sqsClient.createQueue(request);
GetQueueUrlRequest getQueueRequest = GetQueueUrlRequest.builder()
.queueName(queueName)
.build();
String queueUrl = sqsClient.getQueueUrl(getQueueRequest).queueUrl();
SendMessageRequest sendMsgRequest = SendMessageRequest.builder()
.queueUrl(queueUrl)
.messageBody(message)
.delaySeconds(5)
.build();
sqsClient.sendMessage(sendMsgRequest);
} catch (SqsException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
}
}
```
Send a message with a body and message attributes.
```
/**
* This method demonstrates how to add message attributes to a message.
* Each attribute must specify a name, value, and data type. You use a Java Map to supply the attributes. The map's
* key is the attribute name, and you specify the map's entry value using a builder that includes the attribute
* value and data type.
*
* The data type must start with one of "String", "Number" or "Binary". You can optionally
* define a custom extension by using a "." and your extension.
*
* The SQS Developer Guide provides more information on @see message
* attributes.
*
* @param thumbailPath Filesystem path of the image.
* @param queueUrl URL of the SQS queue.
*/
static void sendMessageWithAttributes(Path thumbailPath, String queueUrl) {
Map messageAttributeMap;
try {
messageAttributeMap = Map.of(
"Name", MessageAttributeValue.builder()
.stringValue("Jane Doe")
.dataType("String").build(),
"Age", MessageAttributeValue.builder()
.stringValue("42")
.dataType("Number.int").build(),
"Image", MessageAttributeValue.builder()
.binaryValue(SdkBytes.fromByteArray(Files.readAllBytes(thumbailPath)))
.dataType("Binary.jpg").build()
);
} catch (IOException e) {
LOGGER.error("An I/O exception occurred reading thumbnail image: {}", e.getMessage(), e);
throw new RuntimeException(e);
}
SendMessageRequest request = SendMessageRequest.builder()
.queueUrl(queueUrl)
.messageBody("Hello SQS")
.messageAttributes(messageAttributeMap)
.build();
try {
SendMessageResponse sendMessageResponse = SQS_CLIENT.sendMessage(request);
LOGGER.info("Message ID: {}", sendMessageResponse.messageId());
} catch (SqsException e) {
LOGGER.error("Exception occurred sending message: {}", e.getMessage(), e);
throw new RuntimeException(e);
}
}
```
+ For API details, see [SendMessage](https://docs.aws.amazon.com/goto/SdkForJavaV2/sqs-2012-11-05/SendMessage) in *AWS SDK for Java 2.x API Reference*.
------
#### [ JavaScript ]
**SDK for JavaScript (v3)**
There's more on GitHub. Find the complete example and learn how to set up and run in the [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javascriptv3/example_code/sqs#code-examples).
Send a message to an Amazon SQS queue.
```
import { SendMessageCommand, SQSClient } from "@aws-sdk/client-sqs";
const client = new SQSClient({});
const SQS_QUEUE_URL = "queue_url";
export const main = async (sqsQueueUrl = SQS_QUEUE_URL) => {
const command = new SendMessageCommand({
QueueUrl: sqsQueueUrl,
DelaySeconds: 10,
MessageAttributes: {
Title: {
DataType: "String",
StringValue: "The Whistler",
},
Author: {
DataType: "String",
StringValue: "John Grisham",
},
WeeksOn: {
DataType: "Number",
StringValue: "6",
},
},
MessageBody:
"Information about current NY Times fiction bestseller for week of 12/11/2016.",
});
const response = await client.send(command);
console.log(response);
return response;
};
```
+ For more information, see [AWS SDK for JavaScript Developer Guide](https://docs.aws.amazon.com/sdk-for-javascript/v3/developer-guide/sqs-examples-send-receive-messages.html#sqs-examples-send-receive-messages-sending).
+ For API details, see [SendMessage](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/sqs/command/SendMessageCommand) in *AWS SDK for JavaScript API Reference*.
**SDK for JavaScript (v2)**
There's more on GitHub. Find the complete example and learn how to set up and run in the [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javascript/example_code/sqs#code-examples).
Send a message to an Amazon SQS queue.
```
// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });
// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });
var params = {
// Remove DelaySeconds parameter and value for FIFO queues
DelaySeconds: 10,
MessageAttributes: {
Title: {
DataType: "String",
StringValue: "The Whistler",
},
Author: {
DataType: "String",
StringValue: "John Grisham",
},
WeeksOn: {
DataType: "Number",
StringValue: "6",
},
},
MessageBody:
"Information about current NY Times fiction bestseller for week of 12/11/2016.",
// MessageDeduplicationId: "TheWhistler", // Required for FIFO queues
// MessageGroupId: "Group1", // Required for FIFO queues
QueueUrl: "SQS_QUEUE_URL",
};
sqs.sendMessage(params, function (err, data) {
if (err) {
console.log("Error", err);
} else {
console.log("Success", data.MessageId);
}
});
```
+ For more information, see [AWS SDK for JavaScript Developer Guide](https://docs.aws.amazon.com/sdk-for-javascript/v2/developer-guide/sqs-examples-send-receive-messages.html#sqs-examples-send-receive-messages-sending).
+ For API details, see [SendMessage](https://docs.aws.amazon.com/goto/AWSJavaScriptSDK/sqs-2012-11-05/SendMessage) in *AWS SDK for JavaScript API Reference*.
------
#### [ Kotlin ]
**SDK for Kotlin**
There's more on GitHub. Find the complete example and learn how to set up and run in the [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/sqs#code-examples).
```
suspend fun sendMessages(
queueUrlVal: String,
message: String,
) {
println("Sending multiple messages")
println("\nSend message")
val sendRequest =
SendMessageRequest {
queueUrl = queueUrlVal
messageBody = message
delaySeconds = 10
}
SqsClient.fromEnvironment { region = "us-east-1" }.use { sqsClient ->
sqsClient.sendMessage(sendRequest)
println("A single message was successfully sent.")
}
}
suspend fun sendBatchMessages(queueUrlVal: String?) {
println("Sending multiple messages")
val msg1 =
SendMessageBatchRequestEntry {
id = "id1"
messageBody = "Hello from msg 1"
}
val msg2 =
SendMessageBatchRequestEntry {
id = "id2"
messageBody = "Hello from msg 2"
}
val sendMessageBatchRequest =
SendMessageBatchRequest {
queueUrl = queueUrlVal
entries = listOf(msg1, msg2)
}
SqsClient.fromEnvironment { region = "us-east-1" }.use { sqsClient ->
sqsClient.sendMessageBatch(sendMessageBatchRequest)
println("Batch message were successfully sent.")
}
}
```
+ For API details, see [SendMessage](https://sdk.amazonaws.com/kotlin/api/latest/index.html) in *AWS SDK for Kotlin API reference*.
------
#### [ PowerShell ]
**Tools for PowerShell V4**
**Example 1: This example sends a message with the specified attributes and message body to the specified queue with message delivery delayed for 10 seconds.**
```
$cityAttributeValue = New-Object Amazon.SQS.Model.MessageAttributeValue
$cityAttributeValue.DataType = "String"
$cityAttributeValue.StringValue = "AnyCity"
$populationAttributeValue = New-Object Amazon.SQS.Model.MessageAttributeValue
$populationAttributeValue.DataType = "Number"
$populationAttributeValue.StringValue = "1250800"
$messageAttributes = New-Object System.Collections.Hashtable
$messageAttributes.Add("City", $cityAttributeValue)
$messageAttributes.Add("Population", $populationAttributeValue)
Send-SQSMessage -DelayInSeconds 10 -MessageAttributes $messageAttributes -MessageBody "Information about the largest city in Any Region." -QueueUrl https://sqs.us-east-1.amazonaws.com/80398EXAMPLE/MyQueue
```
**Output:**
```
MD5OfMessageAttributes MD5OfMessageBody MessageId
---------------------- ---------------- ---------
1d3e51347bc042efbdf6dda31EXAMPLE 51b0a3256d59467f973009b73EXAMPLE c35fed8f-c739-4d0c-818b-1820eEXAMPLE
```
+ For API details, see [SendMessage](https://docs.aws.amazon.com/powershell/v4/reference) in *AWS Tools for PowerShell Cmdlet Reference (V4)*.
**Tools for PowerShell V5**
**Example 1: This example sends a message with the specified attributes and message body to the specified queue with message delivery delayed for 10 seconds.**
```
$cityAttributeValue = New-Object Amazon.SQS.Model.MessageAttributeValue
$cityAttributeValue.DataType = "String"
$cityAttributeValue.StringValue = "AnyCity"
$populationAttributeValue = New-Object Amazon.SQS.Model.MessageAttributeValue
$populationAttributeValue.DataType = "Number"
$populationAttributeValue.StringValue = "1250800"
$messageAttributes = New-Object System.Collections.Hashtable
$messageAttributes.Add("City", $cityAttributeValue)
$messageAttributes.Add("Population", $populationAttributeValue)
Send-SQSMessage -DelayInSeconds 10 -MessageAttributes $messageAttributes -MessageBody "Information about the largest city in Any Region." -QueueUrl https://sqs.us-east-1.amazonaws.com/80398EXAMPLE/MyQueue
```
**Output:**
```
MD5OfMessageAttributes MD5OfMessageBody MessageId
---------------------- ---------------- ---------
1d3e51347bc042efbdf6dda31EXAMPLE 51b0a3256d59467f973009b73EXAMPLE c35fed8f-c739-4d0c-818b-1820eEXAMPLE
```
+ For API details, see [SendMessage](https://docs.aws.amazon.com/powershell/v5/reference) in *AWS Tools for PowerShell Cmdlet Reference (V5)*.
------
#### [ Python ]
**SDK for Python (Boto3)**
There's more on GitHub. Find the complete example and learn how to set up and run in the [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/sqs#code-examples).
```
def send_message(queue, message_body, message_attributes=None):
"""
Send a message to an Amazon SQS queue.
:param queue: The queue that receives the message.
:param message_body: The body text of the message.
:param message_attributes: Custom attributes of the message. These are key-value
pairs that can be whatever you want.
:return: The response from SQS that contains the assigned message ID.
"""
if not message_attributes:
message_attributes = {}
try:
response = queue.send_message(
MessageBody=message_body, MessageAttributes=message_attributes
)
except ClientError as error:
logger.exception("Send message failed: %s", message_body)
raise error
else:
return response
```
+ For API details, see [SendMessage](https://docs.aws.amazon.com/goto/boto3/sqs-2012-11-05/SendMessage) in *AWS SDK for Python (Boto3) API Reference*.
------
#### [ Ruby ]
**SDK for Ruby**
There's more on GitHub. Find the complete example and learn how to set up and run in the [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/ruby/example_code/sqs#code-examples).
```
require 'aws-sdk-sqs'
require 'aws-sdk-sts'
# @param sqs_client [Aws::SQS::Client] An initialized Amazon SQS client.
# @param queue_url [String] The URL of the queue.
# @param message_body [String] The contents of the message to be sent.
# @return [Boolean] true if the message was sent; otherwise, false.
# @example
# exit 1 unless message_sent?(
# Aws::SQS::Client.new(region: 'us-west-2'),
# 'https://sqs.us-west-2.amazonaws.com/111111111111/my-queue',
# 'This is my message.'
# )
def message_sent?(sqs_client, queue_url, message_body)
sqs_client.send_message(
queue_url: queue_url,
message_body: message_body
)
true
rescue StandardError => e
puts "Error sending message: #{e.message}"
false
end
# Full example call:
# Replace us-west-2 with the AWS Region you're using for Amazon SQS.
def run_me
region = 'us-west-2'
queue_name = 'my-queue'
message_body = 'This is my message.'
sts_client = Aws::STS::Client.new(region: region)
# For example:
# 'https://sqs.us-west-2.amazonaws.com/111111111111/my-queue'
queue_url = "https://sqs.#{region}.amazonaws.com/#{sts_client.get_caller_identity.account}/#{queue_name}"
sqs_client = Aws::SQS::Client.new(region: region)
puts "Sending a message to the queue named '#{queue_name}'..."
if message_sent?(sqs_client, queue_url, message_body)
puts 'Message sent.'
else
puts 'Message not sent.'
end
end
# Example usage:
run_me if $PROGRAM_NAME == __FILE__
```
+ For API details, see [SendMessage](https://docs.aws.amazon.com/goto/SdkForRubyV3/sqs-2012-11-05/SendMessage) in *AWS SDK for Ruby API Reference*.
------
#### [ Rust ]
**SDK for Rust**
There's more on GitHub. Find the complete example and learn how to set up and run in the [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/rustv1/examples/sqs#code-examples).
```
async fn send(client: &Client, queue_url: &String, message: &SQSMessage) -> Result<(), Error> {
println!("Sending message to queue with URL: {}", queue_url);
let rsp = client
.send_message()
.queue_url(queue_url)
.message_body(&message.body)
// If the queue is FIFO, you need to set .message_deduplication_id
// and message_group_id or configure the queue for ContentBasedDeduplication.
.send()
.await?;
println!("Send message to the queue: {:#?}", rsp);
Ok(())
}
```
+ For API details, see [SendMessage](https://docs.rs/aws-sdk-sqs/latest/aws_sdk_sqs/client/struct.Client.html#method.send_message) in *AWS SDK for Rust API reference*.
------
#### [ SAP ABAP ]
**SDK for SAP ABAP**
There's more on GitHub. Find the complete example and learn how to set up and run in the [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sqs#code-examples).
```
TRY.
oo_result = lo_sqs->sendmessage( " oo_result is returned for testing purposes. "
iv_queueurl = iv_queue_url
iv_messagebody = iv_message ).
MESSAGE 'Message sent to SQS queue.' TYPE 'I'.
CATCH /aws1/cx_sqsinvalidmsgconts.
MESSAGE 'Message contains non-valid characters.' TYPE 'E'.
CATCH /aws1/cx_sqsunsupportedop.
MESSAGE 'Operation not supported.' TYPE 'E'.
ENDTRY.
```
+ For API details, see [SendMessage](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html) in *AWS SDK for SAP ABAP API reference*.
------