From 1566e3ad817b61c8805fe743a97eab4e1de60d95 Mon Sep 17 00:00:00 2001 From: Mathieu LEFEBVRE Date: Mon, 6 Jul 2026 10:40:27 +0200 Subject: [PATCH 1/2] java/iot3core: v0.2.1-dev Signed-off-by: Mathieu LEFEBVRE --- java/iot3/core/build.gradle | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/java/iot3/core/build.gradle b/java/iot3/core/build.gradle index 1610321f..a98d250a 100644 --- a/java/iot3/core/build.gradle +++ b/java/iot3/core/build.gradle @@ -12,7 +12,7 @@ plugins { } group 'com.orange.iot3core' -version '0.2.0' +version '0.2.1-dev' repositories { // Use Maven Central for resolving dependencies. From 6fcc8ffcc74f32ae2f1fa9d720a8b43edc51dbb0 Mon Sep 17 00:00:00 2001 From: Mathieu LEFEBVRE Date: Wed, 17 Jun 2026 16:27:35 +0200 Subject: [PATCH 2/2] java/iot3core: add retain span attribute Note: this attribute is only present for retained messages (received and published), absent otherwise. Signed-off-by: Mathieu LEFEBVRE --- .../src/main/java/com/orange/iot3core/clients/MqttClient.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/java/iot3/core/src/main/java/com/orange/iot3core/clients/MqttClient.java b/java/iot3/core/src/main/java/com/orange/iot3core/clients/MqttClient.java index e9178371..f799c87b 100644 --- a/java/iot3/core/src/main/java/com/orange/iot3core/clients/MqttClient.java +++ b/java/iot3/core/src/main/java/com/orange/iot3core/clients/MqttClient.java @@ -303,6 +303,8 @@ public void publishMessage(String topic, String message, boolean retained, int q span.setAttribute(AttributeKey.stringKey("iot3.core.mqtt.topic"), topic); span.setAttribute(AttributeKey.stringKey("iot3.core.mqtt.payload_size"), String.valueOf(message.length())); + if(retained) + span.setAttribute(AttributeKey.booleanKey("iot3.core.mqtt.retain"), true); span.setAttribute(AttributeKey.stringKey("iot3.core.sdk_language"), "java"); // Inject the trace context into a map @@ -385,6 +387,8 @@ public String get(Map carrier, String key) { publish.getTopic().toString()); receivedSpan.setAttribute(AttributeKey.stringKey("iot3.core.mqtt.payload_size"), String.valueOf(message.length())); + if(publish.isRetain()) + receivedSpan.setAttribute(AttributeKey.booleanKey("iot3.core.mqtt.retain"), true); receivedSpan.setAttribute(AttributeKey.stringKey("iot3.core.sdk_language"), "java"); receivedSpan.end(); }