From 1f09bbc5f0ec07a14acf428121985f3f0a0938ef Mon Sep 17 00:00:00 2001
From: CHANDRASHEKHAR S BYADGI <chandru.b@samsung.com>
Date: Fri, 26 Aug 2022 12:04:26 +0530
Subject: [PATCH] MQTT connect fail handling at android

---
 .../main/java/com/samsung/android/aitt/Aitt.java    | 21 +++++++++++++++++----
 .../java/com/samsung/android/aitt/AittUnitTest.java | 10 ++++++++--
 2 files changed, 25 insertions(+), 6 deletions(-)

diff --git a/android/aitt/src/main/java/com/samsung/android/aitt/Aitt.java b/android/aitt/src/main/java/com/samsung/android/aitt/Aitt.java
index af11dc3..45137fd 100644
--- a/android/aitt/src/main/java/com/samsung/android/aitt/Aitt.java
+++ b/android/aitt/src/main/java/com/samsung/android/aitt/Aitt.java
@@ -122,6 +122,7 @@ public class Aitt {
     public interface ConnectionCallback {
         void onConnected();
         void onDisconnected();
+        void onConnectionFailed();
     }
 
     /**
@@ -473,12 +474,24 @@ public class Aitt {
     /**
      * Method invoked from JNI layer to Java layer for MQTT connection status update
      * @param status Status of the MQTT connection
+     *   0: MQTT Connection disconnected
+     *   1: MQTT connection success
+     *   2: MQTT connection failed
      */
     private void connectionStatusCallback(int status) {
-        if (status == 0) {
-            connectionCallback.onDisconnected();
-        } else {
-            connectionCallback.onConnected();
+
+        switch (status) {
+            case 0:
+                connectionCallback.onDisconnected();
+                break;
+            case 1:
+                connectionCallback.onConnected();
+                break;
+            case 2:
+                connectionCallback.onConnectionFailed();
+                break;
+            default:
+                break;
         }
     }
 
diff --git a/android/aitt/src/test/java/com/samsung/android/aitt/AittUnitTest.java b/android/aitt/src/test/java/com/samsung/android/aitt/AittUnitTest.java
index a7d1789..1fd2362 100644
--- a/android/aitt/src/test/java/com/samsung/android/aitt/AittUnitTest.java
+++ b/android/aitt/src/test/java/com/samsung/android/aitt/AittUnitTest.java
@@ -639,10 +639,16 @@ public class AittUnitTest {
          assertNotNull("Aitt Instance not null", aitt);
          aitt.setConnectionCallback(new Aitt.ConnectionCallback() {
             @Override
-            public void onConnected() {}
+            public void onConnected() {
+            }
 
             @Override
-            public void onDisconnected() {}
+            public void onDisconnected() {
+            }
+
+            @Override
+            public void onConnectionFailed() {
+            }
          });
          aitt.connect(brokerIp, port);
 
-- 
2.7.4