diff --git a/gradle/script-ext.gradle b/gradle/script-ext.gradle index 76cbe66..04d41c4 100644 --- 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 index 6210624..ab0e549 100644 --- 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() + ) } } }