AWS-MQTT Connection

Question

Hello.
I'm using Amazon Web Services and I need to send/receive information from the AWS IoT Platform. But I'm unable to send or receive messages. It seems to me that there some issue with my connection to the platform. And, after double-checking my codes, I finally narrowed my problem down to the MQTT. Since I'm relatively new to the Internet of Things and Networking, I could've messed that part of the code. Could anybody help me with the script for the message broker connecting to the platform?
TIA!

Answer 1

Well, this is a code I had running for my connection to the AWS IoT Platform. I think it might be what you're looking for. Should solve your problem, try it:  

credentialsProvider = new CognitoCachingCredentialsProvider(
            getApplicationContext(), // context
            COGNITO_POOL_ID, // Identity Pool ID
            MY_REGION // Region);

    Region region = Region.getRegion(MY_REGION);

    // MQTT Client
    mqttManager = new AWSIotMqttManager(clientId, CUSTOMER_SPECIFIC_ENDPOINT);

    // Set keepalive to 10 seconds.  Will recognize disconnects more quickly but will also send
    // MQTT pings every 10 seconds.
    mqttManager.setKeepAlive(10);
    mIotAndroidClient = new AWSIotClient(credentialsProvider);
    mIotAndroidClient.setRegion(region);
    try {
            mqttManager.connect(clientKeyStore, new AWSIotMqttClientStatusCallback() {
                @Override
                public void onStatusChanged(final AWSIotMqttClientStatus status,
                        final Throwable throwable) {
                    Log.d(LOG_TAG, "Status = " + String.valueOf(status));

                    runOnUiThread(new Runnable() {
                        @Override
                        public void run() {
                            if (status == AWSIotMqttClientStatus.Connecting) {
                                                               } else if (status == AWSIotMqttClientStatus.Connected) {
                                tvStatus.setText("Connected");

                            } else if (status == AWSIotMqttClientStatus.Reconnecting) {
                                if (throwable != null) {
                                    Log.e(LOG_TAG, "Connection error.", throwable);
                                }
                                tvStatus.setText("Reconnecting");
                            } else if (status == AWSIotMqttClientStatus.ConnectionLost) {
                                if (throwable != null) {
                                    Log.e(LOG_TAG, "Connection error.", throwable);
                                }
                                                                                    }
                        }
                    });
                }
            });
        } catch (final Exception e) {
                }

Let's check out this AWS Certification training to learn more.

Comments

how did you get the "clientKeyStore" and where is mIotAndroidClient being used?

---

Hi@Sweety,

Check the above code properly. Also when you use the methods or class check their document. You will get an idea of how to use them.

Answer 2

Link --> https://docs.aws.amazon.com/greengrass/latest/developerguide/module3-I.html

This is Very Helpful to you.If Your Coding is in Python.Its too much easy to You.