Getting started

You are currently viewing the AWS SDK for Mobile documentation which is a collection of low-level libraries. Use the Amplify libraries for all new app development. Learn more

PubSub provides connectivity with cloud-based message-oriented middleware. You can use PubSub to pass messages between your app instances and your app's backend creating real-time interactive experiences.

PubSub is available with AWS IoT.

When using AWS IoT your PubSub HTTP requests are automatically signed when sending your messages.

Installation and Configuration


In the PubSub category, AWSIoTMqttManager establishes a signed connection with AWS IoT according to Signature Version 4.

Set up AWS Mobile SDK components by including the following libraries in your app/build.gradle dependencies list.

dependencies { implementation 'com.amazonaws:aws-android-sdk-iot:ANDROID_SDK_VERSION' implementation 'com.amazonaws:aws-android-sdk-mobile-client:ANDROID_SDK_VERSION' }
1dependencies {
2 implementation 'com.amazonaws:aws-android-sdk-iot:ANDROID_SDK_VERSION'
3 implementation 'com.amazonaws:aws-android-sdk-mobile-client:ANDROID_SDK_VERSION'
  • aws-android-sdk-iot library enables connecting to AWS IoT.
  • aws-android-sdk-mobile-client library gives access to the AWS credentials provider and configurations.

To use in your app, import the following classes:

import com.amazonaws.mobileconnectors.iot.AWSIotMqttManager; import com.amazonaws.mobileconnectors.iot.AWSIotMqttNewMessageCallback; import com.amazonaws.mobileconnectors.iot.AWSIotMqttQos;
1import com.amazonaws.mobileconnectors.iot.AWSIotMqttManager;
2import com.amazonaws.mobileconnectors.iot.AWSIotMqttNewMessageCallback;
3import com.amazonaws.mobileconnectors.iot.AWSIotMqttQos;

Define your unique client ID and endpoint (incl. region) in your configuration:

// Initialize the AWSIotMqttManager with the configuration AWSIotMqttManager mqttManager = new AWSIotMqttManager( "<YOUR_CLIENT_ID>", "xxxxxxxxxxxxx-ats.iot.<YOUR-AWS-REGION>");
1// Initialize the AWSIotMqttManager with the configuration
2AWSIotMqttManager mqttManager = new AWSIotMqttManager(
4 "xxxxxxxxxxxxx-ats.iot.<YOUR-AWS-REGION>");

You can get the endpoint information from the IoT Core -> Settings page on the AWS Console.

Create IAM policies for AWS IoT

To use PubSub with AWS IoT, you will need to create the necessary IAM policies in the AWS IoT Console, and attach them to your Amazon Cognito Identity.

Go to IoT Core and choose Secure from the left navigation pane, and then Policies from the dropdown menu. Next, click Create. The following myIOTPolicy policy will allow full access to all the topics.

Shows IoT policy dropdown on AWS Console

Attach your policy to your Amazon Cognito Identity

To attach the policy to your Cognito Identity, begin by retrieving the Cognito Identity Id from AWSMobileClient.


Then, you need to attach the myIOTPolicy policy to the user's Cognito Identity Id with the following AWS CLI command:

aws iot attach-principal-policy --policy-name 'myIOTPolicy' --principal '<YOUR_COGNITO_IDENTITY_ID>'
1aws iot attach-principal-policy --policy-name 'myIOTPolicy' --principal '<YOUR_COGNITO_IDENTITY_ID>'

To programmatically attach the myIOTPolicy policy to the user's Cognito Identity Id, import the following classes:

import; import; import;

Next, instantiate the AttachPolicyRequest class and attach it your IoT Client as follows:

AttachPolicyRequest attachPolicyReq = new AttachPolicyRequest(); attachPolicyReq.setPolicyName("myIOTPolicy"); // name of your IOT AWS policy attachPolicyReq.setTarget(AWSMobileClient.getInstance().getIdentityId()); AWSIotClient mIotAndroidClient = new AWSIotClient(AWSMobileClient.getInstance()); mIotAndroidClient.setRegion(Region.getRegion("<YOUR-AWS-REGION>")); // name of your IoT Region such as "us-east-1" mIotAndroidClient.attachPolicy(attachPolicyReq);
1AttachPolicyRequest attachPolicyReq = new AttachPolicyRequest();
2attachPolicyReq.setPolicyName("myIOTPolicy"); // name of your IOT AWS policy
4AWSIotClient mIotAndroidClient = new AWSIotClient(AWSMobileClient.getInstance());
5mIotAndroidClient.setRegion(Region.getRegion("<YOUR-AWS-REGION>")); // name of your IoT Region such as "us-east-1"