Merge pull request #8 from ShareChat/handle_unsubscribe_topic_length_…

…crash Handled crash for topic length
ShareChat · Jun 7, 2023 · cec1526 · cec1526
2 parents e048eb3 + 088e371
commit cec1526
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/gradle/script-ext.gradle b/gradle/script-ext.gradle
@@ -1,5 +1,5 @@
 ext {
     gitVersionCode = ""//grgit.tag.list().size()
-    gitVersionName = "0.2.0"//grgit.describe(tags: true, always: true)
+    gitVersionName = "0.3.0"//grgit.describe(tags: true, always: true)
     println("version : $gitVersionName")
 }
diff --git a/mqtt-client/src/main/java/com/gojek/mqtt/connection/MqttConnection.kt b/mqtt-client/src/main/java/com/gojek/mqtt/connection/MqttConnection.kt
@@ -537,6 +537,15 @@ internal class MqttConnection(
                     timeTakenMillis = (clock.nanoTime() - unsubscribeStartTime).fromNanosToMillis()
                 )
                 runnableScheduler.scheduleMqttHandleExceptionRunnable(mqttException, true)
+            } catch (illegalArgumentException: IllegalArgumentException) {
+                connectionConfig.connectionEventHandler.onMqttUnsubscribeFailure(
+                    topics = topics,
+                    throwable = MqttException(
+                        REASON_CODE_INVALID_SUBSCRIPTION.toInt(),
+                        illegalArgumentException
+                    ),
+                    timeTakenMillis = (clock.nanoTime() - unsubscribeStartTime).fromNanosToMillis()
+                )
             }
         }
     }