Java
Java
SQS Receive Message
See more Amazon SQS Examples
Retrieves one or more messages from an Amazon SQS queue, with a maximum limit of 10 messages, from the specified queue.See SQS ReceiveMessage or detailed information.
Chilkat Java Downloads
import com.chilkatsoft.*;
public class ChilkatExample {
static {
try {
System.loadLibrary("chilkat");
} catch (UnsatisfiedLinkError e) {
System.err.println("Native code library failed to load.\n" + e);
System.exit(1);
}
}
public static void main(String argv[])
{
boolean success = false;
// This example requires the Chilkat API to have been previously unlocked.
// See Global Unlock Sample for sample code.
CkRest rest = new CkRest();
// Connect to the Amazon AWS REST server.
// such as https://sqs.us-west-2.amazonaws.com/
boolean bTls = true;
int port = 443;
boolean bAutoReconnect = true;
success = rest.Connect("sqs.us-west-2.amazonaws.com",port,bTls,bAutoReconnect);
// Provide AWS credentials for the REST call.
CkAuthAws authAws = new CkAuthAws();
authAws.put_AccessKey("AWS_ACCESS_KEY");
authAws.put_SecretKey("AWS_SECRET_KEY");
// the region should match our URL above..
authAws.put_Region("us-west-2");
authAws.put_ServiceName("sqs");
rest.SetAuthAws(authAws);
rest.AddQueryParam("Action","ReceiveMessage");
rest.AddQueryParam("MaxNumberOfMessages","5");
rest.AddQueryParam("VisibilityTimeout","15");
rest.AddQueryParam("AttributeName","All");
rest.AddQueryParam("MessageAttributeName","All");
// Use the actual path part of your SQS queue URL here:
String responseXml = rest.fullRequestNoBody("GET","/123456789123/chilkatTest");
if (rest.get_LastMethodSuccess() != true) {
System.out.println(rest.lastErrorText());
return;
}
// A successful response will have a status code equal to 200.
if (rest.get_ResponseStatusCode() != 200) {
System.out.println("response status code = " + rest.get_ResponseStatusCode());
System.out.println("response status text = " + rest.responseStatusText());
System.out.println("response header: " + rest.responseHeader());
System.out.println("response body: " + responseXml);
return;
}
// Examine the successful XML response.
CkXml xml = new CkXml();
xml.LoadXml(responseXml);
System.out.println(xml.getXml());
System.out.println("----");
// A successful response looks like this:
// <?xml version="1.0" encoding="utf-8" ?>
// <ReceiveMessageResponse xmlns="http://queue.amazonaws.com/doc/2012-11-05/">
// <ReceiveMessageResult>
// <Message>
// <Body>this is a test</Body>
// <MD5OfBody>54b0c58c7ce9f2a8b551351102ee0938</MD5OfBody>
// <ReceiptHandle>AQEBMyLof...UbKBTvHtEg==</ReceiptHandle>
// <Attribute>
// <Name>SenderId</Name>
// <Value>957491831129</Value>
// </Attribute>
// <Attribute>
// <Name>ApproximateFirstReceiveTimestamp</Name>
// <Value>1475013283557</Value>
// </Attribute>
// <Attribute>
// <Name>ApproximateReceiveCount</Name>
// <Value>4</Value>
// </Attribute>
// <Attribute>
// <Name>SentTimestamp</Name>
// <Value>1475013283557</Value>
// </Attribute>
// <MessageId>52882c65-5e21-4450-9024-93a3b01e61d3</MessageId>
// <MD5OfMessageAttributes>2ff68603f4239272bd03f543254ed040</MD5OfMessageAttributes>
// </Message>
// </ReceiveMessageResult>
// <ResponseMetadata>
// <RequestId>05ba5c92-80ee-5f87-be76-0cf67b7475d6</RequestId>
// </ResponseMetadata>
// </ReceiveMessageResponse>
// Get some values from the XML:
System.out.println("Body: " + xml.chilkatPath("ReceiveMessageResult|Message|Body|*"));
System.out.println("MessageId: " + xml.chilkatPath("ReceiveMessageResult|Message|MessageId|*"));
String unused = xml.chilkatPath("ReceiveMessageResult|Message[0]|Attribute|$");
CkXml rec = xml.FindNextRecord("Name","SenderId");
System.out.println("SenderId: " + rec.getChildContent("Value"));
rec = xml.FindNextRecord("Name","ApproximateFirstReceiveTimestamp");
System.out.println("ApproximateFirstReceiveTimestamp: " + rec.getChildContent("Value"));
rec = xml.FindNextRecord("Name","ApproximateReceiveCount");
System.out.println("ApproximateReceiveCount: " + rec.getChildContent("Value"));
rec = xml.FindNextRecord("Name","SentTimestamp");
System.out.println("SentTimestamp: " + rec.getChildContent("Value"));
xml.GetRoot2();
}
}