From 1239f6376d9b3f8f435867032f47a78141cf3ade Mon Sep 17 00:00:00 2001 From: ballerina-bot Date: Wed, 9 Oct 2024 22:14:21 +0000 Subject: [PATCH 1/9] Update simple_publisher_subscriber test results on Wed Oct 9 22:14:21 UTC 2024 --- load-tests/simple_publisher_subscriber/results/summary.csv | 1 + 1 file changed, 1 insertion(+) diff --git a/load-tests/simple_publisher_subscriber/results/summary.csv b/load-tests/simple_publisher_subscriber/results/summary.csv index a1c3bd9..ff67e8c 100644 --- a/load-tests/simple_publisher_subscriber/results/summary.csv +++ b/load-tests/simple_publisher_subscriber/results/summary.csv @@ -184,3 +184,4 @@ MQTT Simple Publisher Subscriber,35681,0.10091869049610426,0,0,0,0,0,0,0.0,9.908 MQTT Simple Publisher Subscriber,35683,0.10089293162530127,0,0,0,0,0,0,0.0,9.911497107783779,0,0,1728252848,0,1 MQTT Simple Publisher Subscriber,35680,0.10091786498234255,0,0,0,0,0,0,0.0,9.90904831542927,0,0,1728339211,0,1 MQTT Simple Publisher Subscriber,35702,0.10086237737214643,0,0,0,0,0,0,0.0,9.914499598897558,0,0,1728428180,0,1 +MQTT Simple Publisher Subscriber,35697,0.10086120337847378,0,0,0,0,0,0,0.0,9.91461500065172,0,0,1728512013,0,1 From ce0d267e320babb5f3fc1a6dbd2ffc65e7edf97a Mon Sep 17 00:00:00 2001 From: ballerina-bot Date: Thu, 10 Oct 2024 22:16:08 +0000 Subject: [PATCH 2/9] Update simple_publisher_subscriber test results on Thu Oct 10 22:16:08 UTC 2024 --- load-tests/simple_publisher_subscriber/results/summary.csv | 1 + 1 file changed, 1 insertion(+) diff --git a/load-tests/simple_publisher_subscriber/results/summary.csv b/load-tests/simple_publisher_subscriber/results/summary.csv index ff67e8c..12dac84 100644 --- a/load-tests/simple_publisher_subscriber/results/summary.csv +++ b/load-tests/simple_publisher_subscriber/results/summary.csv @@ -185,3 +185,4 @@ MQTT Simple Publisher Subscriber,35683,0.10089293162530127,0,0,0,0,0,0,0.0,9.911 MQTT Simple Publisher Subscriber,35680,0.10091786498234255,0,0,0,0,0,0,0.0,9.90904831542927,0,0,1728339211,0,1 MQTT Simple Publisher Subscriber,35702,0.10086237737214643,0,0,0,0,0,0,0.0,9.914499598897558,0,0,1728428180,0,1 MQTT Simple Publisher Subscriber,35697,0.10086120337847378,0,0,0,0,0,0,0.0,9.91461500065172,0,0,1728512013,0,1 +MQTT Simple Publisher Subscriber,35698,0.10086439610897274,0,0,0,0,0,0,0.0,9.914301166485064,0,0,1728598505,0,1 From b2da23ea83d3d30c57eea1317c27e8cb0e168264 Mon Sep 17 00:00:00 2001 From: ballerina-bot Date: Fri, 11 Oct 2024 22:24:14 +0000 Subject: [PATCH 3/9] Update simple_publisher_subscriber test results on Fri Oct 11 22:24:14 UTC 2024 --- load-tests/simple_publisher_subscriber/results/summary.csv | 1 + 1 file changed, 1 insertion(+) diff --git a/load-tests/simple_publisher_subscriber/results/summary.csv b/load-tests/simple_publisher_subscriber/results/summary.csv index 12dac84..11748bc 100644 --- a/load-tests/simple_publisher_subscriber/results/summary.csv +++ b/load-tests/simple_publisher_subscriber/results/summary.csv @@ -186,3 +186,4 @@ MQTT Simple Publisher Subscriber,35680,0.10091786498234255,0,0,0,0,0,0,0.0,9.909 MQTT Simple Publisher Subscriber,35702,0.10086237737214643,0,0,0,0,0,0,0.0,9.914499598897558,0,0,1728428180,0,1 MQTT Simple Publisher Subscriber,35697,0.10086120337847378,0,0,0,0,0,0,0.0,9.91461500065172,0,0,1728512013,0,1 MQTT Simple Publisher Subscriber,35698,0.10086439610897274,0,0,0,0,0,0,0.0,9.914301166485064,0,0,1728598505,0,1 +MQTT Simple Publisher Subscriber,35649,0.10099239830265372,0,0,0,0,0,0,0.0,9.901735346488188,0,0,1728685351,0,1 From 8ef536a2af17b556b71ab1add4fb6bb38f7c0061 Mon Sep 17 00:00:00 2001 From: ballerina-bot Date: Sat, 12 Oct 2024 22:13:47 +0000 Subject: [PATCH 4/9] Update simple_publisher_subscriber test results on Sat Oct 12 22:13:47 UTC 2024 --- load-tests/simple_publisher_subscriber/results/summary.csv | 1 + 1 file changed, 1 insertion(+) diff --git a/load-tests/simple_publisher_subscriber/results/summary.csv b/load-tests/simple_publisher_subscriber/results/summary.csv index 11748bc..d1458b5 100644 --- a/load-tests/simple_publisher_subscriber/results/summary.csv +++ b/load-tests/simple_publisher_subscriber/results/summary.csv @@ -187,3 +187,4 @@ MQTT Simple Publisher Subscriber,35702,0.10086237737214643,0,0,0,0,0,0,0.0,9.914 MQTT Simple Publisher Subscriber,35697,0.10086120337847378,0,0,0,0,0,0,0.0,9.91461500065172,0,0,1728512013,0,1 MQTT Simple Publisher Subscriber,35698,0.10086439610897274,0,0,0,0,0,0,0.0,9.914301166485064,0,0,1728598505,0,1 MQTT Simple Publisher Subscriber,35649,0.10099239830265372,0,0,0,0,0,0,0.0,9.901735346488188,0,0,1728685351,0,1 +MQTT Simple Publisher Subscriber,35711,0.10083494494690563,0,0,0,0,0,0,0.0,9.917196865893539,0,0,1728771169,0,1 From 06b1affd10ca1c55bbe1fb2260064b82ebfe82de Mon Sep 17 00:00:00 2001 From: ballerina-bot Date: Sun, 13 Oct 2024 22:15:24 +0000 Subject: [PATCH 5/9] Update simple_publisher_subscriber test results on Sun Oct 13 22:15:24 UTC 2024 --- load-tests/simple_publisher_subscriber/results/summary.csv | 1 + 1 file changed, 1 insertion(+) diff --git a/load-tests/simple_publisher_subscriber/results/summary.csv b/load-tests/simple_publisher_subscriber/results/summary.csv index d1458b5..e263085 100644 --- a/load-tests/simple_publisher_subscriber/results/summary.csv +++ b/load-tests/simple_publisher_subscriber/results/summary.csv @@ -188,3 +188,4 @@ MQTT Simple Publisher Subscriber,35697,0.10086120337847378,0,0,0,0,0,0,0.0,9.914 MQTT Simple Publisher Subscriber,35698,0.10086439610897274,0,0,0,0,0,0,0.0,9.914301166485064,0,0,1728598505,0,1 MQTT Simple Publisher Subscriber,35649,0.10099239830265372,0,0,0,0,0,0,0.0,9.901735346488188,0,0,1728685351,0,1 MQTT Simple Publisher Subscriber,35711,0.10083494494690563,0,0,0,0,0,0,0.0,9.917196865893539,0,0,1728771169,0,1 +MQTT Simple Publisher Subscriber,35697,0.10086273332084827,0,0,0,0,0,0,0.0,9.914464610223888,0,0,1728857674,0,1 From 579e684c75fc4d62de6dce2a2c5b7c3dbfba7057 Mon Sep 17 00:00:00 2001 From: ballerina-bot Date: Mon, 14 Oct 2024 22:14:22 +0000 Subject: [PATCH 6/9] Update simple_publisher_subscriber test results on Mon Oct 14 22:14:22 UTC 2024 --- load-tests/simple_publisher_subscriber/results/summary.csv | 1 + 1 file changed, 1 insertion(+) diff --git a/load-tests/simple_publisher_subscriber/results/summary.csv b/load-tests/simple_publisher_subscriber/results/summary.csv index e263085..eb8a94b 100644 --- a/load-tests/simple_publisher_subscriber/results/summary.csv +++ b/load-tests/simple_publisher_subscriber/results/summary.csv @@ -189,3 +189,4 @@ MQTT Simple Publisher Subscriber,35698,0.10086439610897274,0,0,0,0,0,0,0.0,9.914 MQTT Simple Publisher Subscriber,35649,0.10099239830265372,0,0,0,0,0,0,0.0,9.901735346488188,0,0,1728685351,0,1 MQTT Simple Publisher Subscriber,35711,0.10083494494690563,0,0,0,0,0,0,0.0,9.917196865893539,0,0,1728771169,0,1 MQTT Simple Publisher Subscriber,35697,0.10086273332084827,0,0,0,0,0,0,0.0,9.914464610223888,0,0,1728857674,0,1 +MQTT Simple Publisher Subscriber,35688,0.10088545289001598,0,0,0,0,0,0,0.0,9.912231856560997,0,0,1728944015,0,1 From 6c85fb9b47d8e4bca7b90d75cf9ff24e73e078bb Mon Sep 17 00:00:00 2001 From: ballerina-bot Date: Tue, 15 Oct 2024 22:13:26 +0000 Subject: [PATCH 7/9] Update simple_publisher_subscriber test results on Tue Oct 15 22:13:26 UTC 2024 --- load-tests/simple_publisher_subscriber/results/summary.csv | 1 + 1 file changed, 1 insertion(+) diff --git a/load-tests/simple_publisher_subscriber/results/summary.csv b/load-tests/simple_publisher_subscriber/results/summary.csv index eb8a94b..bed9335 100644 --- a/load-tests/simple_publisher_subscriber/results/summary.csv +++ b/load-tests/simple_publisher_subscriber/results/summary.csv @@ -190,3 +190,4 @@ MQTT Simple Publisher Subscriber,35649,0.10099239830265372,0,0,0,0,0,0,0.0,9.901 MQTT Simple Publisher Subscriber,35711,0.10083494494690563,0,0,0,0,0,0,0.0,9.917196865893539,0,0,1728771169,0,1 MQTT Simple Publisher Subscriber,35697,0.10086273332084827,0,0,0,0,0,0,0.0,9.914464610223888,0,0,1728857674,0,1 MQTT Simple Publisher Subscriber,35688,0.10088545289001598,0,0,0,0,0,0,0.0,9.912231856560997,0,0,1728944015,0,1 +MQTT Simple Publisher Subscriber,35695,0.10087680190359725,0,0,0,0,0,0,0.0,9.91308190911572,0,0,1729030357,0,1 From c8986651a9bfb9ab796159c712a780acdffa6709 Mon Sep 17 00:00:00 2001 From: ballerina-bot Date: Wed, 16 Oct 2024 22:15:43 +0000 Subject: [PATCH 8/9] Update simple_publisher_subscriber test results on Wed Oct 16 22:15:43 UTC 2024 --- load-tests/simple_publisher_subscriber/results/summary.csv | 1 + 1 file changed, 1 insertion(+) diff --git a/load-tests/simple_publisher_subscriber/results/summary.csv b/load-tests/simple_publisher_subscriber/results/summary.csv index bed9335..5e93f5b 100644 --- a/load-tests/simple_publisher_subscriber/results/summary.csv +++ b/load-tests/simple_publisher_subscriber/results/summary.csv @@ -191,3 +191,4 @@ MQTT Simple Publisher Subscriber,35711,0.10083494494690563,0,0,0,0,0,0,0.0,9.917 MQTT Simple Publisher Subscriber,35697,0.10086273332084827,0,0,0,0,0,0,0.0,9.914464610223888,0,0,1728857674,0,1 MQTT Simple Publisher Subscriber,35688,0.10088545289001598,0,0,0,0,0,0,0.0,9.912231856560997,0,0,1728944015,0,1 MQTT Simple Publisher Subscriber,35695,0.10087680190359725,0,0,0,0,0,0,0.0,9.91308190911572,0,0,1729030357,0,1 +MQTT Simple Publisher Subscriber,35682,0.1009024973237017,0,0,0,0,0,0,0.0,9.910557483943492,0,0,1729116898,0,1 From 35bb9ab730ece1c1469b16bfa92f3e7fce7c63ff Mon Sep 17 00:00:00 2001 From: ravinperera00 Date: Wed, 13 Nov 2024 17:26:16 +0530 Subject: [PATCH 9/9] Migrate to new Runtime APIs --- ballerina/Ballerina.toml | 8 ++++---- ballerina/CompilerPlugin.toml | 2 +- ballerina/Dependencies.toml | 16 ++++++++-------- build-config/resources/Ballerina.toml | 2 +- gradle.properties | 18 +++++++++--------- .../listener/MqttListenerCallbackImpl.java | 8 ++++---- 6 files changed, 27 insertions(+), 27 deletions(-) diff --git a/ballerina/Ballerina.toml b/ballerina/Ballerina.toml index ef468f7..a3a28ab 100644 --- a/ballerina/Ballerina.toml +++ b/ballerina/Ballerina.toml @@ -1,11 +1,11 @@ [package] org = "ballerina" name = "mqtt" -version = "1.2.0" +version = "1.2.1" authors = ["ballerina"] keywords = ["mqtt", "client", "messaging", "network", "pubsub", "iot"] repository = "https://github.com/ballerina-platform/module-ballerina-mqtt" -distribution = "2201.10.0-20241007-143200-6b69ca80" +distribution = "2201.11.0-20241112-214900-6b80ab87" [platform.java21] graalvmCompatible = true @@ -13,8 +13,8 @@ graalvmCompatible = true [[platform.java21.dependency]] groupId = "io.ballerina.stdlib" artifactId = "mqtt-native" -version = "1.2.0" -path = "../native/build/libs/mqtt-native-1.2.0.jar" +version = "1.2.1" +path = "../native/build/libs/mqtt-native-1.2.1-SNAPSHOT.jar" [[platform.java21.dependency]] groupId = "org.eclipse.paho" diff --git a/ballerina/CompilerPlugin.toml b/ballerina/CompilerPlugin.toml index 81322c7..8e930b8 100644 --- a/ballerina/CompilerPlugin.toml +++ b/ballerina/CompilerPlugin.toml @@ -3,4 +3,4 @@ id = "mqtt-compiler-plugin" class = "io.ballerina.stdlib.mqtt.compiler.MqttCompilerPlugin" [[dependency]] -path = "../compiler-plugin/build/libs/mqtt-compiler-plugin-1.2.0.jar" +path = "../compiler-plugin/build/libs/mqtt-compiler-plugin-1.2.1-SNAPSHOT.jar" diff --git a/ballerina/Dependencies.toml b/ballerina/Dependencies.toml index 36f2f6c..d0e6369 100644 --- a/ballerina/Dependencies.toml +++ b/ballerina/Dependencies.toml @@ -5,12 +5,12 @@ [ballerina] dependencies-toml-version = "2" -distribution-version = "2201.10.0-20241007-143200-6b69ca80" +distribution-version = "2201.11.0-20241112-214900-6b80ab87" [[package]] org = "ballerina" name = "crypto" -version = "2.7.2" +version = "2.7.3" dependencies = [ {org = "ballerina", name = "jballerina.java"}, {org = "ballerina", name = "time"} @@ -22,7 +22,7 @@ modules = [ [[package]] org = "ballerina" name = "io" -version = "1.6.1" +version = "1.6.2" scope = "testOnly" dependencies = [ {org = "ballerina", name = "jballerina.java"}, @@ -107,7 +107,7 @@ dependencies = [ [[package]] org = "ballerina" name = "log" -version = "2.10.0" +version = "2.10.1" scope = "testOnly" dependencies = [ {org = "ballerina", name = "io"}, @@ -122,7 +122,7 @@ modules = [ [[package]] org = "ballerina" name = "mqtt" -version = "1.2.0" +version = "1.2.1" dependencies = [ {org = "ballerina", name = "crypto"}, {org = "ballerina", name = "jballerina.java"}, @@ -138,7 +138,7 @@ modules = [ [[package]] org = "ballerina" name = "observe" -version = "1.3.0" +version = "1.4.0" scope = "testOnly" dependencies = [ {org = "ballerina", name = "jballerina.java"} @@ -161,7 +161,7 @@ modules = [ [[package]] org = "ballerina" name = "time" -version = "2.4.0" +version = "2.6.0" dependencies = [ {org = "ballerina", name = "jballerina.java"} ] @@ -169,7 +169,7 @@ dependencies = [ [[package]] org = "ballerina" name = "uuid" -version = "1.8.0" +version = "1.8.1" scope = "testOnly" dependencies = [ {org = "ballerina", name = "crypto"}, diff --git a/build-config/resources/Ballerina.toml b/build-config/resources/Ballerina.toml index 948afee..28b79b4 100644 --- a/build-config/resources/Ballerina.toml +++ b/build-config/resources/Ballerina.toml @@ -5,7 +5,7 @@ version = "@toml.version@" authors = ["ballerina"] keywords = ["mqtt", "client", "messaging", "network", "pubsub", "iot"] repository = "https://github.com/ballerina-platform/module-ballerina-mqtt" -distribution = "2201.10.0-20241007-143200-6b69ca80" +distribution = "2201.11.0-20241112-214900-6b80ab87" [platform.java21] graalvmCompatible = true diff --git a/gradle.properties b/gradle.properties index 07731d4..29466f6 100644 --- a/gradle.properties +++ b/gradle.properties @@ -1,7 +1,7 @@ org.gradle.caching=true group=io.ballerina.stdlib version=1.2.1-SNAPSHOT -ballerinaLangVersion=2201.10.0-20241011-152000-627c5bb0 +ballerinaLangVersion=2201.11.0-20241112-214900-6b80ab87 checkstylePluginVersion=10.12.1 spotbugsPluginVersion=6.0.18 @@ -20,16 +20,16 @@ pahoMqtt5Version=1.2.5 #stdlib dependencies # Level 01 -stdlibTimeVersion=2.5.1-20240930-120200-e59222b -stdlibIoVersion=1.6.2-20240928-084100-656404f +stdlibTimeVersion=2.6.0-20241113-073800-201b904 +stdlibIoVersion=1.6.2-20241112-233100-995cf5f # Level 02 -stdlibLogVersion=2.10.1-20240930-154200-5ab2aa4 -stdlibCryptoVersion=2.7.3-20240930-132000-5ecc9ab -stdlibRandomVersion=1.5.1-20240930-193000-e5c6c0e +stdlibLogVersion=2.10.1-20241113-120000-4577868 +stdlibCryptoVersion=2.7.3-20241113-081400-d015a39 +stdlibRandomVersion=1.5.1-20241113-122300-1bc770e # Level 03 -stdlibUuidVersion=1.8.1-20241009-134600-a05012b +stdlibUuidVersion=1.8.1-20241113-154400-443c67b -observeVersion=1.3.1-20241007-161000-645452d -observeInternalVersion=1.3.1-20241007-182700-a5f77a1 +observeVersion=1.4.0-20241113-092000-b83ae74 +observeInternalVersion=1.3.1-20241113-101700-265054d diff --git a/native/src/main/java/io/ballerina/stdlib/mqtt/listener/MqttListenerCallbackImpl.java b/native/src/main/java/io/ballerina/stdlib/mqtt/listener/MqttListenerCallbackImpl.java index debacde..35ff8f5 100644 --- a/native/src/main/java/io/ballerina/stdlib/mqtt/listener/MqttListenerCallbackImpl.java +++ b/native/src/main/java/io/ballerina/stdlib/mqtt/listener/MqttListenerCallbackImpl.java @@ -110,14 +110,14 @@ private void invokeOnMessage(MqttMessage message, String topic) { message.getProperties().getCorrelationData()); } try { - Object result = runtime.call(service, MqttConstants.ONMESSAGE, bMqttMessage, callerObject); + Object result = runtime.callMethod(service, MqttConstants.ONMESSAGE, null, bMqttMessage, callerObject); Util.notifySuccess(result); } catch (BError bError) { Util.notifyFailure(bError); } } else { try { - Object result = runtime.call(service, MqttConstants.ONMESSAGE, bMqttMessage); + Object result = runtime.callMethod(service, MqttConstants.ONMESSAGE, null, bMqttMessage); Util.notifySuccess(result); } catch (BError bError) { Util.notifyFailure(bError); @@ -131,7 +131,7 @@ private void invokeOnError(BError bError) { return; } try { - Object result = runtime.call(service, MqttConstants.ONERROR, bError); + Object result = runtime.callMethod(service, MqttConstants.ONERROR, null, bError); Util.notifySuccess(result); } catch (BError error) { Util.notifyFailure(error); @@ -145,7 +145,7 @@ private void invokeOnComplete(IMqttToken token) { BMap bMqttToken; bMqttToken = getMqttDeliveryToken(token); try { - Object result = runtime.call(service, MqttConstants.ONCOMPLETE, bMqttToken); + Object result = runtime.callMethod(service, MqttConstants.ONCOMPLETE, null, bMqttToken); Util.notifySuccess(result); } catch (BError bError) { Util.notifyFailure(bError);