Android™
Android™
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 Android™ Downloads
// Important: Don't forget to include the call to System.loadLibrary
// as shown at the bottom of this code sample.
package com.test;
import android.app.Activity;
import com.chilkatsoft.*;
import android.widget.TextView;
import android.os.Bundle;
public class SimpleActivity extends Activity {
private static final String TAG = "Chilkat";
// Called when the activity is first created.
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
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) {
Log.i(TAG, rest.lastErrorText());
return;
}
// A successful response will have a status code equal to 200.
if (rest.get_ResponseStatusCode() != 200) {
Log.i(TAG, "response status code = " + String.valueOf(rest.get_ResponseStatusCode()));
Log.i(TAG, "response status text = " + rest.responseStatusText());
Log.i(TAG, "response header: " + rest.responseHeader());
Log.i(TAG, "response body: " + responseXml);
return;
}
// Examine the successful XML response.
CkXml xml = new CkXml();
xml.LoadXml(responseXml);
Log.i(TAG, xml.getXml());
Log.i(TAG, "----");
// 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:
Log.i(TAG, "Body: " + xml.chilkatPath("ReceiveMessageResult|Message|Body|*"));
Log.i(TAG, "MessageId: " + xml.chilkatPath("ReceiveMessageResult|Message|MessageId|*"));
String unused = xml.chilkatPath("ReceiveMessageResult|Message[0]|Attribute|$");
CkXml rec = xml.FindNextRecord("Name","SenderId");
Log.i(TAG, "SenderId: " + rec.getChildContent("Value"));
rec = xml.FindNextRecord("Name","ApproximateFirstReceiveTimestamp");
Log.i(TAG, "ApproximateFirstReceiveTimestamp: " + rec.getChildContent("Value"));
rec = xml.FindNextRecord("Name","ApproximateReceiveCount");
Log.i(TAG, "ApproximateReceiveCount: " + rec.getChildContent("Value"));
rec = xml.FindNextRecord("Name","SentTimestamp");
Log.i(TAG, "SentTimestamp: " + rec.getChildContent("Value"));
xml.GetRoot2();
}
static {
System.loadLibrary("chilkat");
// Note: If the incorrect library name is passed to System.loadLibrary,
// then you will see the following error message at application startup:
//"The application <your-application-name> has stopped unexpectedly. Please try again."
}
}